Package com.google.bigtable.v2
Class ReadChangeStreamResponse.CloseStream
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- com.google.bigtable.v2.ReadChangeStreamResponse.CloseStream
-
- All Implemented Interfaces:
ReadChangeStreamResponse.CloseStreamOrBuilder,com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable
- Enclosing class:
- ReadChangeStreamResponse
public static final class ReadChangeStreamResponse.CloseStream extends com.google.protobuf.GeneratedMessageV3 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- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classReadChangeStreamResponse.CloseStream.BuilderA message indicating that the client should stop reading from the stream.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intCONTINUATION_TOKENS_FIELD_NUMBERstatic intNEW_PARTITIONS_FIELD_NUMBERstatic intSTATUS_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)StreamContinuationTokengetContinuationTokens(int index)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.static ReadChangeStreamResponse.CloseStreamgetDefaultInstance()ReadChangeStreamResponse.CloseStreamgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()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`.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.protobuf.Parser<ReadChangeStreamResponse.CloseStream>getParserForType()intgetSerializedSize()com.google.rpc.StatusgetStatus()The status of the stream.com.google.rpc.StatusOrBuildergetStatusOrBuilder()The status of the stream.inthashCode()booleanhasStatus()The status of the stream.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static ReadChangeStreamResponse.CloseStream.BuildernewBuilder()static ReadChangeStreamResponse.CloseStream.BuildernewBuilder(ReadChangeStreamResponse.CloseStream prototype)ReadChangeStreamResponse.CloseStream.BuildernewBuilderForType()protected ReadChangeStreamResponse.CloseStream.BuildernewBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)protected ObjectnewInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)static ReadChangeStreamResponse.CloseStreamparseDelimitedFrom(InputStream input)static ReadChangeStreamResponse.CloseStreamparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadChangeStreamResponse.CloseStreamparseFrom(byte[] data)static ReadChangeStreamResponse.CloseStreamparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadChangeStreamResponse.CloseStreamparseFrom(com.google.protobuf.ByteString data)static ReadChangeStreamResponse.CloseStreamparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadChangeStreamResponse.CloseStreamparseFrom(com.google.protobuf.CodedInputStream input)static ReadChangeStreamResponse.CloseStreamparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadChangeStreamResponse.CloseStreamparseFrom(InputStream input)static ReadChangeStreamResponse.CloseStreamparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadChangeStreamResponse.CloseStreamparseFrom(ByteBuffer data)static ReadChangeStreamResponse.CloseStreamparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<ReadChangeStreamResponse.CloseStream>parser()ReadChangeStreamResponse.CloseStream.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
STATUS_FIELD_NUMBER
public static final int STATUS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
CONTINUATION_TOKENS_FIELD_NUMBER
public static final int CONTINUATION_TOKENS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
NEW_PARTITIONS_FIELD_NUMBER
public static final int NEW_PARTITIONS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
newInstance
protected Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstancein classcom.google.protobuf.GeneratedMessageV3
-
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
-
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.
-
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
-
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
-
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
-
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
-
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
-
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
-
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
-
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
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessageV3- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ReadChangeStreamResponse.CloseStream parseDelimitedFrom(InputStream input) throws IOException
- Throws:
IOException
-
parseDelimitedFrom
public static ReadChangeStreamResponse.CloseStream parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
- Throws:
IOException
-
parseFrom
public static ReadChangeStreamResponse.CloseStream parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Throws:
IOException
-
newBuilderForType
public ReadChangeStreamResponse.CloseStream.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static ReadChangeStreamResponse.CloseStream.Builder newBuilder()
-
newBuilder
public static ReadChangeStreamResponse.CloseStream.Builder newBuilder(ReadChangeStreamResponse.CloseStream prototype)
-
toBuilder
public ReadChangeStreamResponse.CloseStream.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected ReadChangeStreamResponse.CloseStream.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static ReadChangeStreamResponse.CloseStream getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<ReadChangeStreamResponse.CloseStream> parser()
-
getParserForType
public com.google.protobuf.Parser<ReadChangeStreamResponse.CloseStream> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public ReadChangeStreamResponse.CloseStream getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-