Interface ChangeStreamRecord.PartitionStartRecordOrBuilder (6.102.0) 

public static interface ChangeStreamRecord.PartitionStartRecordOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

getPartitionTokens(int index)

public abstract String getPartitionTokens(int index)

Unique partition identifiers to be used in queries.

repeated string partition_tokens = 3;

Parameter
Name Description
index int

The index of the element to return.
Returns
Type Description
String

The partitionTokens at the given index.

getPartitionTokensBytes(int index)

public abstract ByteString getPartitionTokensBytes(int index)

Unique partition identifiers to be used in queries.

repeated string partition_tokens = 3;

Parameter
Name Description
index int

The index of the value to return.
Returns
Type Description
ByteString

The bytes of the partitionTokens at the given index.

getPartitionTokensCount()

public abstract int getPartitionTokensCount()

Unique partition identifiers to be used in queries.

repeated string partition_tokens = 3;

Returns
Type Description
int

The count of partitionTokens.

getPartitionTokensList()

public abstract List<String> getPartitionTokensList()

Unique partition identifiers to be used in queries.

repeated string partition_tokens = 3;

Returns
Type Description
List<String>

A list containing the partitionTokens.

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.

getStartTimestamp()

public abstract Timestamp getStartTimestamp()

Start timestamp at which the partitions should be queried to return change stream records with timestamps >= start_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition.

.google.protobuf.Timestamp start_timestamp = 1;

Returns
Type Description
Timestamp

The startTimestamp.

getStartTimestampOrBuilder()

public abstract TimestampOrBuilder getStartTimestampOrBuilder()

Start timestamp at which the partitions should be queried to return change stream records with timestamps >= start_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition.

.google.protobuf.Timestamp start_timestamp = 1;

Returns
Type Description
TimestampOrBuilder

hasStartTimestamp()

public abstract boolean hasStartTimestamp()

Start timestamp at which the partitions should be queried to return change stream records with timestamps >= start_timestamp. DataChangeRecord.commit_timestamps, PartitionStartRecord.start_timestamps, PartitionEventRecord.commit_timestamps, and PartitionEndRecord.end_timestamps can have the same value in the same partition.

.google.protobuf.Timestamp start_timestamp = 1;

Returns
Type Description
boolean

Whether the startTimestamp field is set.