public static final class ChangeStreamRecord.PartitionEndRecord.Builder extends GeneratedMessageV3.Builder<ChangeStreamRecord.PartitionEndRecord.Builder> implements ChangeStreamRecord.PartitionEndRecordOrBuilder
A partition end record serves as a notification that the client should stop
reading the partition. No further records are expected to be retrieved on
it.
Protobuf type google.spanner.v1.ChangeStreamRecord.PartitionEndRecord
Inherited Members
com.google.protobuf.GeneratedMessageV3.Builder.getUnknownFieldSetBuilder()
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMapFieldReflection(int)
com.google.protobuf.GeneratedMessageV3.Builder.internalGetMutableMapFieldReflection(int)
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownLengthDelimitedField(int,com.google.protobuf.ByteString)
com.google.protobuf.GeneratedMessageV3.Builder.mergeUnknownVarintField(int,int)
com.google.protobuf.GeneratedMessageV3.Builder.parseUnknownField(com.google.protobuf.CodedInputStream,com.google.protobuf.ExtensionRegistryLite,int)
com.google.protobuf.GeneratedMessageV3.Builder.setUnknownFieldSetBuilder(com.google.protobuf.UnknownFieldSet.Builder)
Static Methods
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
Methods
addRepeatedField(Descriptors.FieldDescriptor field, Object value)
public ChangeStreamRecord.PartitionEndRecord.Builder addRepeatedField(Descriptors.FieldDescriptor field, Object value)
Overrides
build()
public ChangeStreamRecord.PartitionEndRecord build()
buildPartial()
public ChangeStreamRecord.PartitionEndRecord buildPartial()
clear()
public ChangeStreamRecord.PartitionEndRecord.Builder clear()
Overrides
clearEndTimestamp()
public ChangeStreamRecord.PartitionEndRecord.Builder clearEndTimestamp()
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;
clearField(Descriptors.FieldDescriptor field)
public ChangeStreamRecord.PartitionEndRecord.Builder clearField(Descriptors.FieldDescriptor field)
Overrides
clearOneof(Descriptors.OneofDescriptor oneof)
public ChangeStreamRecord.PartitionEndRecord.Builder clearOneof(Descriptors.OneofDescriptor oneof)
Overrides
clearPartitionToken()
public ChangeStreamRecord.PartitionEndRecord.Builder clearPartitionToken()
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;
clearRecordSequence()
public ChangeStreamRecord.PartitionEndRecord.Builder clearRecordSequence()
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;
clone()
public ChangeStreamRecord.PartitionEndRecord.Builder clone()
Overrides
getDefaultInstanceForType()
public ChangeStreamRecord.PartitionEndRecord getDefaultInstanceForType()
getDescriptorForType()
public Descriptors.Descriptor getDescriptorForType()
Overrides
getEndTimestamp()
public 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.
|
getEndTimestampBuilder()
public Timestamp.Builder getEndTimestampBuilder()
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;
getEndTimestampOrBuilder()
public 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;
getPartitionToken()
public 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 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 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 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 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.
|
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
mergeEndTimestamp(Timestamp value)
public ChangeStreamRecord.PartitionEndRecord.Builder mergeEndTimestamp(Timestamp value)
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;
public ChangeStreamRecord.PartitionEndRecord.Builder mergeFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Overrides
mergeFrom(Message other)
public ChangeStreamRecord.PartitionEndRecord.Builder mergeFrom(Message other)
Parameter |
Name |
Description |
other |
Message
|
Overrides
mergeFrom(ChangeStreamRecord.PartitionEndRecord other)
public ChangeStreamRecord.PartitionEndRecord.Builder mergeFrom(ChangeStreamRecord.PartitionEndRecord other)
mergeUnknownFields(UnknownFieldSet unknownFields)
public final ChangeStreamRecord.PartitionEndRecord.Builder mergeUnknownFields(UnknownFieldSet unknownFields)
Overrides
setEndTimestamp(Timestamp value)
public ChangeStreamRecord.PartitionEndRecord.Builder setEndTimestamp(Timestamp value)
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;
setEndTimestamp(Timestamp.Builder builderForValue)
public ChangeStreamRecord.PartitionEndRecord.Builder setEndTimestamp(Timestamp.Builder builderForValue)
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;
Parameter |
Name |
Description |
builderForValue |
Builder
|
setField(Descriptors.FieldDescriptor field, Object value)
public ChangeStreamRecord.PartitionEndRecord.Builder setField(Descriptors.FieldDescriptor field, Object value)
Overrides
setPartitionToken(String value)
public ChangeStreamRecord.PartitionEndRecord.Builder setPartitionToken(String value)
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;
Parameter |
Name |
Description |
value |
String
The partitionToken to set.
|
setPartitionTokenBytes(ByteString value)
public ChangeStreamRecord.PartitionEndRecord.Builder setPartitionTokenBytes(ByteString value)
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;
Parameter |
Name |
Description |
value |
ByteString
The bytes for partitionToken to set.
|
setRecordSequence(String value)
public ChangeStreamRecord.PartitionEndRecord.Builder setRecordSequence(String value)
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;
Parameter |
Name |
Description |
value |
String
The recordSequence to set.
|
setRecordSequenceBytes(ByteString value)
public ChangeStreamRecord.PartitionEndRecord.Builder setRecordSequenceBytes(ByteString value)
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;
Parameter |
Name |
Description |
value |
ByteString
The bytes for recordSequence to set.
|
setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
public ChangeStreamRecord.PartitionEndRecord.Builder setRepeatedField(Descriptors.FieldDescriptor field, int index, Object value)
Overrides
setUnknownFields(UnknownFieldSet unknownFields)
public final ChangeStreamRecord.PartitionEndRecord.Builder setUnknownFields(UnknownFieldSet unknownFields)
Overrides