public static interface ChangeStreamRecord.PartitionEndRecordOrBuilder extends MessageOrBuilderImplements
MessageOrBuilderMethods
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. |