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

Class ChangeStreamRecordMetadata

java.lang.Object
org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChangeStreamRecordMetadata
All Implemented Interfaces:
Serializable
@DefaultCoder(AvroCoder.class) public class ChangeStreamRecordMetadata extends Object implements Serializable
Holds internal execution metrics / metadata for the processed ChangeStreamRecord.
See Also:

  • Method Details

    • getPartitionToken

      public String getPartitionToken()
      The partition token that produced this change stream record.

    • getRecordTimestamp

      public com.google.cloud.Timestamp getRecordTimestamp()
      The Cloud Spanner timestamp time when this record occurred.

    • getPartitionStartTimestamp

      public com.google.cloud.Timestamp getPartitionStartTimestamp()
      The start time for the partition change stream query, which produced this record.

    • getPartitionEndTimestamp

      public com.google.cloud.Timestamp getPartitionEndTimestamp()
      The end time for the partition change stream query, which produced this record.

    • getPartitionCreatedAt

      public com.google.cloud.Timestamp getPartitionCreatedAt()
      The time at which this partition was first detected and created in the metadata table.

    • getPartitionScheduledAt

      @Nullable public com.google.cloud.Timestamp getPartitionScheduledAt()
      The time at which this partition was scheduled to be queried.

    • getPartitionRunningAt

      @Nullable public com.google.cloud.Timestamp getPartitionRunningAt()
      The time at which the connector started processing this partition.

    • getQueryStartedAt

      public com.google.cloud.Timestamp getQueryStartedAt()
      The time that the change stream query which produced this record started.

    • getRecordStreamStartedAt

      public com.google.cloud.Timestamp getRecordStreamStartedAt()
      The time at which the record started to be streamed.

    • getRecordStreamEndedAt

      public com.google.cloud.Timestamp getRecordStreamEndedAt()
      The time at which the record finished streaming.

    • getRecordReadAt

      public com.google.cloud.Timestamp getRecordReadAt()
      The time at which the record was fully read.

    • getTotalStreamTimeMillis

      public long getTotalStreamTimeMillis()
      The total streaming time (in millis) for this record.

    • getNumberOfRecordsRead

      public long getNumberOfRecordsRead()
      The number of records read in the partition change stream query before reading this record.

    • equals

      public boolean equals(@Nullable Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • newBuilder

      public static ChangeStreamRecordMetadata.Builder newBuilder()