Class DefaultChangeStreamRecordAdapter (2.44.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
Type Description
ChangeStreamRecordBuilder<ChangeStreamRecord>

getTokenFromChangeStreamMutation(ChangeStreamRecord record)

public String getTokenFromChangeStreamMutation(ChangeStreamRecord record)
Parameter
Name Description
record ChangeStreamRecord
Returns
Type Description
String

getTokenFromHeartbeat(ChangeStreamRecord record)

public String getTokenFromHeartbeat(ChangeStreamRecord record)
Parameter
Name Description
record ChangeStreamRecord
Returns
Type Description
String

isChangeStreamMutation(ChangeStreamRecord record)

public boolean isChangeStreamMutation(ChangeStreamRecord record)
Parameter
Name Description
record ChangeStreamRecord
Returns
Type Description
boolean

isHeartbeat(ChangeStreamRecord record)

public boolean isHeartbeat(ChangeStreamRecord record)
Parameter
Name Description
record ChangeStreamRecord
Returns
Type Description
boolean