org.apache.beam.sdk.io.gcp.spanner.changestreams.model

Interface ChangeStreamRecord

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

ChildPartitionsRecord, DataChangeRecord, HeartbeatRecord

public interface ChangeStreamRecord
extends java.io.Serializable

Represents a Spanner Change Stream Record. It can be one of: DataChangeRecord, HeartbeatRecord or ChildPartitionsRecord.

Method Summary

Modifier and Type	Method and Description
com.google.cloud.Timestamp	getRecordTimestamp() The timestamp associated with the record.

Method Detail

getRecordTimestamp

com.google.cloud.Timestamp getRecordTimestamp()

The timestamp associated with the record. It will come from a different value depending on the underlying record implementation.

Returns:

the timestamp at which this record has occurred.