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

Interface ChangeStreamRecord

All Superinterfaces:
Serializable
All Known Implementing Classes:
ChildPartitionsRecord, DataChangeRecord, HeartbeatRecord, PartitionEndRecord, PartitionEventRecord, PartitionStartRecord
public interface ChangeStreamRecord extends Serializable
Represents a Spanner Change Stream Record. It can be one of: DataChangeRecord, HeartbeatRecord or ChildPartitionsRecord.

  • Method Summary

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

  • Method Details

    • 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.