Class DefaultChangeStreamRecordAdapter (2.33.0)

public class DefaultChangeStreamRecordAdapter implements ChangeStreamRecordAdapter<ChangeStreamRecord>

Default implementation of a ChangeStreamRecordAdapter that uses ChangeStreamRecords to represent change stream records.

Inheritance

java.lang.Object > DefaultChangeStreamRecordAdapter

Implements

com.google.cloud.bigtable.data.v2.models.ChangeStreamRecordAdapter<com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord>

Constructors

DefaultChangeStreamRecordAdapter()

public DefaultChangeStreamRecordAdapter()

Methods

createChangeStreamRecordBuilder()

public ChangeStreamRecordAdapter.ChangeStreamRecordBuilder<ChangeStreamRecord> createChangeStreamRecordBuilder()

Creates a new instance of a ChangeStreamRecordBuilder.

Returns
TypeDescription
ChangeStreamRecordBuilder<ChangeStreamRecord>

getTokenFromChangeStreamMutation(ChangeStreamRecord record)

public String getTokenFromChangeStreamMutation(ChangeStreamRecord record)
Parameter
NameDescription
recordChangeStreamRecord
Returns
TypeDescription
String

getTokenFromHeartbeat(ChangeStreamRecord record)

public String getTokenFromHeartbeat(ChangeStreamRecord record)
Parameter
NameDescription
recordChangeStreamRecord
Returns
TypeDescription
String

isChangeStreamMutation(ChangeStreamRecord record)

public boolean isChangeStreamMutation(ChangeStreamRecord record)
Parameter
NameDescription
recordChangeStreamRecord
Returns
TypeDescription
boolean

isHeartbeat(ChangeStreamRecord record)

public boolean isHeartbeat(ChangeStreamRecord record)
Parameter
NameDescription
recordChangeStreamRecord
Returns
TypeDescription
boolean