Class DefaultChangeStreamRecordAdapter (2.39.5)

Version latest

• 2.39.5 (latest)
• 2.39.4
• 2.37.0
• 2.35.1
• 2.34.0
• 2.33.0
• 2.32.0
• 2.31.0
• 2.30.0
• 2.29.1
• 2.28.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>

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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