Interface ChangeStreamRecord.PartitionEndRecordOrBuilder (6.99.0) 

public static interface ChangeStreamRecord.PartitionEndRecordOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getEndTimestamp()

public abstract Timestamp getEndTimestamp()

End timestamp at which the change stream partition is terminated. All changes generated by this partition will have timestamps <= end_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition. PartitionEndRecord is the last record returned for a partition.

.google.protobuf.Timestamp end_timestamp = 1;

Returns
Type Description
Timestamp

The endTimestamp.

getEndTimestampOrBuilder()

public abstract TimestampOrBuilder getEndTimestampOrBuilder()

End timestamp at which the change stream partition is terminated. All changes generated by this partition will have timestamps <= end_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition. PartitionEndRecord is the last record returned for a partition.

.google.protobuf.Timestamp end_timestamp = 1;

Returns
Type Description
TimestampOrBuilder

getPartitionToken()

public abstract String getPartitionToken()

Unique partition identifier describing the terminated change stream partition. partition_token is equal to the partition token of the change stream partition currently queried to return this PartitionEndRecord.

string partition_token = 3;

Returns
Type Description
String

The partitionToken.

getPartitionTokenBytes()

public abstract ByteString getPartitionTokenBytes()

Unique partition identifier describing the terminated change stream partition. partition_token is equal to the partition token of the change stream partition currently queried to return this PartitionEndRecord.

string partition_token = 3;

Returns
Type Description
ByteString

The bytes for partitionToken.

getRecordSequence()

public abstract String getRecordSequence()

Record sequence numbers are unique and monotonically increasing (but not necessarily contiguous) for a specific timestamp across record types in the same partition. To guarantee ordered processing, the reader should process records (of potentially different types) in record_sequence order for a specific timestamp in the same partition.

string record_sequence = 2;

Returns
Type Description
String

The recordSequence.

getRecordSequenceBytes()

public abstract ByteString getRecordSequenceBytes()

Record sequence numbers are unique and monotonically increasing (but not necessarily contiguous) for a specific timestamp across record types in the same partition. To guarantee ordered processing, the reader should process records (of potentially different types) in record_sequence order for a specific timestamp in the same partition.

string record_sequence = 2;

Returns
Type Description
ByteString

The bytes for recordSequence.

hasEndTimestamp()

public abstract boolean hasEndTimestamp()

End timestamp at which the change stream partition is terminated. All changes generated by this partition will have timestamps <= end_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition. PartitionEndRecord is the last record returned for a partition.

.google.protobuf.Timestamp end_timestamp = 1;

Returns
Type Description
boolean

Whether the endTimestamp field is set.