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.BuilderaddAllContinuationTokens(Iterable<? extends StreamContinuationToken> values)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderaddAllNewPartitions(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.BuilderaddContinuationTokens(int index, StreamContinuationToken value)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderaddContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderaddContinuationTokens(StreamContinuationToken value)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderaddContinuationTokens(StreamContinuationToken.Builder builderForValue)If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.BuilderaddContinuationTokensBuilder()If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.BuilderaddContinuationTokensBuilder(int index)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderaddNewPartitions(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.BuilderaddNewPartitions(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.BuilderaddNewPartitions(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.BuilderaddNewPartitions(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.BuilderaddNewPartitionsBuilder()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.BuilderaddNewPartitionsBuilder(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.BuilderaddRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)ReadChangeStreamResponse.CloseStreambuild()ReadChangeStreamResponse.CloseStreambuildPartial()ReadChangeStreamResponse.CloseStream.Builderclear()ReadChangeStreamResponse.CloseStream.BuilderclearContinuationTokens()If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderclearField(com.google.protobuf.Descriptors.FieldDescriptor field)ReadChangeStreamResponse.CloseStream.BuilderclearNewPartitions()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.BuilderclearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)ReadChangeStreamResponse.CloseStream.BuilderclearStatus()The status of the stream.ReadChangeStreamResponse.CloseStream.Builderclone()StreamContinuationTokengetContinuationTokens(int index)If non-empty, contains the information needed to resume reading their associated partitions.StreamContinuationToken.BuildergetContinuationTokensBuilder(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.intgetContinuationTokensCount()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.StreamContinuationTokenOrBuildergetContinuationTokensOrBuilder(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.CloseStreamgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Descriptors.DescriptorgetDescriptorForType()StreamPartitiongetNewPartitions(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.BuildergetNewPartitionsBuilder(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`.intgetNewPartitionsCount()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`.StreamPartitionOrBuildergetNewPartitionsOrBuilder(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.StatusgetStatus()The status of the stream.com.google.rpc.Status.BuildergetStatusBuilder()The status of the stream.com.google.rpc.StatusOrBuildergetStatusOrBuilder()The status of the stream.booleanhasStatus()The status of the stream.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()ReadChangeStreamResponse.CloseStream.BuildermergeFrom(ReadChangeStreamResponse.CloseStream other)ReadChangeStreamResponse.CloseStream.BuildermergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)ReadChangeStreamResponse.CloseStream.BuildermergeFrom(com.google.protobuf.Message other)ReadChangeStreamResponse.CloseStream.BuildermergeStatus(com.google.rpc.Status value)The status of the stream.ReadChangeStreamResponse.CloseStream.BuildermergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)ReadChangeStreamResponse.CloseStream.BuilderremoveContinuationTokens(int index)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuilderremoveNewPartitions(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.BuildersetContinuationTokens(int index, StreamContinuationToken value)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuildersetContinuationTokens(int index, StreamContinuationToken.Builder builderForValue)If non-empty, contains the information needed to resume reading their associated partitions.ReadChangeStreamResponse.CloseStream.BuildersetField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)ReadChangeStreamResponse.CloseStream.BuildersetNewPartitions(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.BuildersetNewPartitions(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.BuildersetRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)ReadChangeStreamResponse.CloseStream.BuildersetStatus(com.google.rpc.Status value)The status of the stream.ReadChangeStreamResponse.CloseStream.BuildersetStatus(com.google.rpc.Status.Builder builderForValue)The status of the stream.ReadChangeStreamResponse.CloseStream.BuildersetUnknownFields(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:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clear
public ReadChangeStreamResponse.CloseStream.Builder clear()
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
getDefaultInstanceForType
public ReadChangeStreamResponse.CloseStream getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
public ReadChangeStreamResponse.CloseStream build()
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public ReadChangeStreamResponse.CloseStream buildPartial()
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
clone
public ReadChangeStreamResponse.CloseStream.Builder clone()
- Specified by:
clonein interfacecom.google.protobuf.Message.Builder- Specified by:
clonein interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clonein classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
setField
public ReadChangeStreamResponse.CloseStream.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
setFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clearField
public ReadChangeStreamResponse.CloseStream.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
- Specified by:
clearFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
clearFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
clearOneof
public ReadChangeStreamResponse.CloseStream.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
- Specified by:
clearOneofin interfacecom.google.protobuf.Message.Builder- Overrides:
clearOneofin 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:
setRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
addRepeatedField
public ReadChangeStreamResponse.CloseStream.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
- Specified by:
addRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
addRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeFrom
public ReadChangeStreamResponse.CloseStream.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeFrom
public ReadChangeStreamResponse.CloseStream.Builder mergeFrom(ReadChangeStreamResponse.CloseStream other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin 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:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin 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:
hasStatusin 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:
getStatusin 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:
getStatusOrBuilderin 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:
getContinuationTokensListin 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:
getContinuationTokensCountin 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:
getContinuationTokensin 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:
getContinuationTokensOrBuilderin 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:
getContinuationTokensOrBuilderListin 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:
getNewPartitionsListin 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:
getNewPartitionsCountin 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:
getNewPartitionsin 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:
getNewPartitionsOrBuilderin 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:
getNewPartitionsOrBuilderListin 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:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
mergeUnknownFields
public final ReadChangeStreamResponse.CloseStream.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.CloseStream.Builder>
-
-