ReadChangeStreamResponse.CloseStream (proto-google-cloud-bigtable-v2 2.78.1 API)

java.lang.Object
- com.google.protobuf.AbstractMessageLite
- - com.google.protobuf.AbstractMessage
  - - com.google.protobuf.GeneratedMessage
    - - 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.GeneratedMessage
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 type google.bigtable.v2.ReadChangeStreamResponse.CloseStream

See Also:: Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class ReadChangeStreamResponse.CloseStream.Builder
A message indicating that the client should stop reading from the stream.
- Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
  com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter
- Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessage
  com.google.protobuf.AbstractMessage.BuilderParent
- Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite
  com.google.protobuf.AbstractMessageLite.InternalOneOfEnum

Nested Classes
Modifier and Type	Class and Description
`static class`	`ReadChangeStreamResponse.CloseStream.Builder` A message indicating that the client should stop reading from the stream.

Field Summary

Fields
Modifier and Type Field and Description

static int CONTINUATION_TOKENS_FIELD_NUMBER

static int NEW_PARTITIONS_FIELD_NUMBER

static int STATUS_FIELD_NUMBER
- Fields inherited from class com.google.protobuf.GeneratedMessage
  alwaysUseFieldBuilders, loggedPre22TypeNames, unknownFields
- Fields inherited from class com.google.protobuf.AbstractMessage
  memoizedSize
- Fields inherited from class com.google.protobuf.AbstractMessageLite
  memoizedHashCode

Fields
Modifier and Type	Field and Description
`static int`	`CONTINUATION_TOKENS_FIELD_NUMBER`
`static int`	`NEW_PARTITIONS_FIELD_NUMBER`
`static int`	`STATUS_FIELD_NUMBER`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`equals(Object obj)`
`StreamContinuationToken`	`getContinuationTokens(int index)` 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.
`static ReadChangeStreamResponse.CloseStream`	`getDefaultInstance()`
`ReadChangeStreamResponse.CloseStream`	`getDefaultInstanceForType()`
`static com.google.protobuf.Descriptors.Descriptor`	`getDescriptor()`
`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`.
`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.protobuf.Parser<ReadChangeStreamResponse.CloseStream>`	`getParserForType()`
`int`	`getSerializedSize()`
`com.google.rpc.Status`	`getStatus()` The status of the stream.
`com.google.rpc.StatusOrBuilder`	`getStatusOrBuilder()` The status of the stream.
`int`	`hashCode()`
`boolean`	`hasStatus()` The status of the stream.
`protected com.google.protobuf.GeneratedMessage.FieldAccessorTable`	`internalGetFieldAccessorTable()`
`boolean`	`isInitialized()`
`static ReadChangeStreamResponse.CloseStream.Builder`	`newBuilder()`
`static ReadChangeStreamResponse.CloseStream.Builder`	`newBuilder(ReadChangeStreamResponse.CloseStream prototype)`
`ReadChangeStreamResponse.CloseStream.Builder`	`newBuilderForType()`
`protected ReadChangeStreamResponse.CloseStream.Builder`	`newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)`
`static ReadChangeStreamResponse.CloseStream`	`parseDelimitedFrom(InputStream input)`
`static ReadChangeStreamResponse.CloseStream`	`parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(byte[] data)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(ByteBuffer data)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(com.google.protobuf.ByteString data)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(com.google.protobuf.CodedInputStream input)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(InputStream input)`
`static ReadChangeStreamResponse.CloseStream`	`parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static com.google.protobuf.Parser<ReadChangeStreamResponse.CloseStream>`	`parser()`
`ReadChangeStreamResponse.CloseStream.Builder`	`toBuilder()`
`void`	`writeTo(com.google.protobuf.CodedOutputStream output)`

Methods inherited from class com.google.protobuf.GeneratedMessage
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, 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, hashFields, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo

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

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable
```
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
```
Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

hasStatus
```
public boolean hasStatus()
```
```
 The status of the stream.
 
```
.google.rpc.Status status = 1;
Specified by:

hasStatus in interface ReadChangeStreamResponse.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 interface ReadChangeStreamResponse.CloseStreamOrBuilder

Returns:

The status.

getStatusOrBuilder
```
public com.google.rpc.StatusOrBuilder getStatusOrBuilder()
```
```
 The status of the stream.
 
```
.google.rpc.Status status = 1;
Specified by:

getStatusOrBuilder in interface ReadChangeStreamResponse.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 interface ReadChangeStreamResponse.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 interface ReadChangeStreamResponse.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 interface ReadChangeStreamResponse.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 interface ReadChangeStreamResponse.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:

getContinuationTokensOrBuilder in interface ReadChangeStreamResponse.CloseStreamOrBuilder