Package com.google.bigtable.v2
Class ReadChangeStreamResponse.CloseStream.Builder
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite.Builder
-
- com.google.protobuf.AbstractMessage.Builder<BuilderT>
-
- com.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
- com.google.bigtable.v2.ReadChangeStreamResponse.CloseStream.Builder
-
- All Implemented Interfaces:
ReadChangeStreamResponse.CloseStreamOrBuilder
,com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
- Enclosing class:
- ReadChangeStreamResponse.CloseStream
public static final class ReadChangeStreamResponse.CloseStream.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder> implements ReadChangeStreamResponse.CloseStreamOrBuilder
A message indicating that the client should stop reading from the stream. If status is OK and `continuation_tokens` & `new_partitions` are empty, the stream has finished (for example if there was an `end_time` specified). If `continuation_tokens` & `new_partitions` are present, then a change in partitioning requires the client to open a new stream for each token to resume reading. Example: [B, D) ends | v new_partitions: [A, C) [C, E) continuation_tokens.partitions: [B,C) [C,D) ^---^ ^---^ ^ ^ | | | StreamContinuationToken 2 | StreamContinuationToken 1 To read the new partition [A,C), supply the continuation tokens whose ranges cover the new partition, for example ContinuationToken[A,B) & ContinuationToken[B,C).
Protobuf typegoogle.bigtable.v2.ReadChangeStreamResponse.CloseStream
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ReadChangeStreamResponse.CloseStream.Builder
addAllContinuationTokens(Iterable<? extends StreamContinuationToken> values)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
addAllNewPartitions(Iterable<? extends StreamPartition> values)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
addContinuationTokens(int index, StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
addContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
addContinuationTokens(StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
addContinuationTokens(StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.Builder
addContinuationTokensBuilder()
If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.Builder
addContinuationTokensBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
addNewPartitions(int index, StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
addNewPartitions(int index, StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
addNewPartitions(StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
addNewPartitions(StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.StreamPartition.Builder
addNewPartitionsBuilder()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.StreamPartition.Builder
addNewPartitionsBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
ReadChangeStreamResponse.CloseStream
build()
ReadChangeStreamResponse.CloseStream
buildPartial()
ReadChangeStreamResponse.CloseStream.Builder
clear()
ReadChangeStreamResponse.CloseStream.Builder
clearContinuationTokens()
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
ReadChangeStreamResponse.CloseStream.Builder
clearNewPartitions()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
ReadChangeStreamResponse.CloseStream.Builder
clearStatus()
The status of the stream.ReadChangeStreamResponse.CloseStream.Builder
clone()
StreamContinuationToken
getContinuationTokens(int index)
If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.Builder
getContinuationTokensBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.List<StreamContinuationToken.Builder>
getContinuationTokensBuilderList()
If non-empty, contains the information needed to resume reading their associated partitions.int
getContinuationTokensCount()
If non-empty, contains the information needed to resume reading their associated partitions.List<StreamContinuationToken>
getContinuationTokensList()
If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationTokenOrBuilder
getContinuationTokensOrBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.List<? extends StreamContinuationTokenOrBuilder>
getContinuationTokensOrBuilderList()
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
com.google.protobuf.Descriptors.Descriptor
getDescriptorForType()
StreamPartition
getNewPartitions(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.StreamPartition.Builder
getNewPartitionsBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.List<StreamPartition.Builder>
getNewPartitionsBuilderList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.int
getNewPartitionsCount()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.List<StreamPartition>
getNewPartitionsList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.StreamPartitionOrBuilder
getNewPartitionsOrBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.List<? extends StreamPartitionOrBuilder>
getNewPartitionsOrBuilderList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.com.google.rpc.Status
getStatus()
The status of the stream.com.google.rpc.Status.Builder
getStatusBuilder()
The status of the stream.com.google.rpc.StatusOrBuilder
getStatusOrBuilder()
The status of the stream.boolean
hasStatus()
The status of the stream.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
ReadChangeStreamResponse.CloseStream.Builder
mergeFrom(ReadChangeStreamResponse.CloseStream other)
ReadChangeStreamResponse.CloseStream.Builder
mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ReadChangeStreamResponse.CloseStream.Builder
mergeFrom(com.google.protobuf.Message other)
ReadChangeStreamResponse.CloseStream.Builder
mergeStatus(com.google.rpc.Status value)
The status of the stream.ReadChangeStreamResponse.CloseStream.Builder
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
ReadChangeStreamResponse.CloseStream.Builder
removeContinuationTokens(int index)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
removeNewPartitions(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
setContinuationTokens(int index, StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
setContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.Builder
setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
ReadChangeStreamResponse.CloseStream.Builder
setNewPartitions(int index, StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
setNewPartitions(int index, StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.ReadChangeStreamResponse.CloseStream.Builder
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
ReadChangeStreamResponse.CloseStream.Builder
setStatus(com.google.rpc.Status value)
The status of the stream.ReadChangeStreamResponse.CloseStream.Builder
setStatus(com.google.rpc.Status.Builder builderForValue)
The status of the stream.ReadChangeStreamResponse.CloseStream.Builder
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
-
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clear
public ReadChangeStreamResponse.CloseStream.Builder clear()
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
getDefaultInstanceForType
public ReadChangeStreamResponse.CloseStream getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
public ReadChangeStreamResponse.CloseStream build()
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public ReadChangeStreamResponse.CloseStream buildPartial()
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
clone
public ReadChangeStreamResponse.CloseStream.Builder clone()
- Specified by:
clone
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clone
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clone
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
setField
public ReadChangeStreamResponse.CloseStream.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
setField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setField
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clearField
public ReadChangeStreamResponse.CloseStream.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
- Specified by:
clearField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearField
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clearOneof
public ReadChangeStreamResponse.CloseStream.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
- Specified by:
clearOneof
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearOneof
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
setRepeatedField
public ReadChangeStreamResponse.CloseStream.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
- Specified by:
setRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
addRepeatedField
public ReadChangeStreamResponse.CloseStream.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
addRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
addRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeFrom
public ReadChangeStreamResponse.CloseStream.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeFrom
public ReadChangeStreamResponse.CloseStream.Builder mergeFrom(ReadChangeStreamResponse.CloseStream other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeFrom
public ReadChangeStreamResponse.CloseStream.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<ReadChangeStreamResponse.CloseStream.Builder>
- Throws:
IOException
-
hasStatus
public boolean hasStatus()
The status of the stream.
.google.rpc.Status status = 1;
- Specified by:
hasStatus
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
- Returns:
- Whether the status field is set.
-
getStatus
public com.google.rpc.Status getStatus()
The status of the stream.
.google.rpc.Status status = 1;
- Specified by:
getStatus
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
- Returns:
- The status.
-
setStatus
public ReadChangeStreamResponse.CloseStream.Builder setStatus(com.google.rpc.Status value)
The status of the stream.
.google.rpc.Status status = 1;
-
setStatus
public ReadChangeStreamResponse.CloseStream.Builder setStatus(com.google.rpc.Status.Builder builderForValue)
The status of the stream.
.google.rpc.Status status = 1;
-
mergeStatus
public ReadChangeStreamResponse.CloseStream.Builder mergeStatus(com.google.rpc.Status value)
The status of the stream.
.google.rpc.Status status = 1;
-
clearStatus
public ReadChangeStreamResponse.CloseStream.Builder clearStatus()
The status of the stream.
.google.rpc.Status status = 1;
-
getStatusBuilder
public com.google.rpc.Status.Builder getStatusBuilder()
The status of the stream.
.google.rpc.Status status = 1;
-
getStatusOrBuilder
public com.google.rpc.StatusOrBuilder getStatusOrBuilder()
The status of the stream.
.google.rpc.Status status = 1;
- Specified by:
getStatusOrBuilder
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getContinuationTokensList
public List<StreamContinuationToken> getContinuationTokensList()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
- Specified by:
getContinuationTokensList
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getContinuationTokensCount
public int getContinuationTokensCount()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
- Specified by:
getContinuationTokensCount
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getContinuationTokens
public StreamContinuationToken getContinuationTokens(int index)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
- Specified by:
getContinuationTokens
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
setContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder setContinuationTokens(int index, StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
setContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder setContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder addContinuationTokens(StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder addContinuationTokens(int index, StreamContinuationToken value)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder addContinuationTokens(StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder addContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addAllContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder addAllContinuationTokens(Iterable<? extends StreamContinuationToken> values)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
clearContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder clearContinuationTokens()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
removeContinuationTokens
public ReadChangeStreamResponse.CloseStream.Builder removeContinuationTokens(int index)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
getContinuationTokensBuilder
public StreamContinuationToken.Builder getContinuationTokensBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
getContinuationTokensOrBuilder
public StreamContinuationTokenOrBuilder getContinuationTokensOrBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
- Specified by:
getContinuationTokensOrBuilder
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getContinuationTokensOrBuilderList
public List<? extends StreamContinuationTokenOrBuilder> getContinuationTokensOrBuilderList()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
- Specified by:
getContinuationTokensOrBuilderList
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
addContinuationTokensBuilder
public StreamContinuationToken.Builder addContinuationTokensBuilder()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
addContinuationTokensBuilder
public StreamContinuationToken.Builder addContinuationTokensBuilder(int index)
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
getContinuationTokensBuilderList
public List<StreamContinuationToken.Builder> getContinuationTokensBuilderList()
If non-empty, contains the information needed to resume reading their associated partitions.
repeated .google.bigtable.v2.StreamContinuationToken continuation_tokens = 2;
-
getNewPartitionsList
public List<StreamPartition> getNewPartitionsList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
- Specified by:
getNewPartitionsList
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getNewPartitionsCount
public int getNewPartitionsCount()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
- Specified by:
getNewPartitionsCount
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getNewPartitions
public StreamPartition getNewPartitions(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
- Specified by:
getNewPartitions
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
setNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder setNewPartitions(int index, StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
setNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder setNewPartitions(int index, StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder addNewPartitions(StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder addNewPartitions(int index, StreamPartition value)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder addNewPartitions(StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder addNewPartitions(int index, StreamPartition.Builder builderForValue)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addAllNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder addAllNewPartitions(Iterable<? extends StreamPartition> values)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
clearNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder clearNewPartitions()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
removeNewPartitions
public ReadChangeStreamResponse.CloseStream.Builder removeNewPartitions(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
getNewPartitionsBuilder
public StreamPartition.Builder getNewPartitionsBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
getNewPartitionsOrBuilder
public StreamPartitionOrBuilder getNewPartitionsOrBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
- Specified by:
getNewPartitionsOrBuilder
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
getNewPartitionsOrBuilderList
public List<? extends StreamPartitionOrBuilder> getNewPartitionsOrBuilderList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
- Specified by:
getNewPartitionsOrBuilderList
in interfaceReadChangeStreamResponse.CloseStreamOrBuilder
-
addNewPartitionsBuilder
public StreamPartition.Builder addNewPartitionsBuilder()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
addNewPartitionsBuilder
public StreamPartition.Builder addNewPartitionsBuilder(int index)
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
getNewPartitionsBuilderList
public List<StreamPartition.Builder> getNewPartitionsBuilderList()
If non-empty, contains the new partitions to start reading from, which are related to but not necessarily identical to the partitions for the above `continuation_tokens`.
repeated .google.bigtable.v2.StreamPartition new_partitions = 3;
-
setUnknownFields
public final ReadChangeStreamResponse.CloseStream.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeUnknownFields
public final ReadChangeStreamResponse.CloseStream.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
-