Package com.google.bigtable.v2

Class ReadChangeStreamResponse.DataChange

  • All Implemented Interfaces:
    ReadChangeStreamResponse.DataChangeOrBuilder, 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.DataChange
extends com.google.protobuf.GeneratedMessageV3
implements ReadChangeStreamResponse.DataChangeOrBuilder
     A message corresponding to one or more mutations to the partition
 being streamed. A single logical `DataChange` message may also be split
 across a sequence of multiple individual messages. Messages other than
 the first in a sequence will only have the `type` and `chunks` fields
 populated, with the final message in the sequence also containing `done`
 set to true.
    Protobuf type google.bigtable.v2.ReadChangeStreamResponse.DataChange
    See Also:
    Serialized Form

    • Method Detail

      • newInstance

        protected Object newInstance​(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
        Overrides:
        newInstance in class com.google.protobuf.GeneratedMessageV3

      • getDescriptor

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

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3

      • getTypeValue

        public int getTypeValue()
         The type of the mutation.
        .google.bigtable.v2.ReadChangeStreamResponse.DataChange.Type type = 1;
        Specified by:
        getTypeValue in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The enum numeric value on the wire for type.

      • getSourceClusterIdBytes

        public com.google.protobuf.ByteString getSourceClusterIdBytes()
         The cluster where the mutation was applied.
 Not set when `type` is `GARBAGE_COLLECTION`.
        string source_cluster_id = 2;
        Specified by:
        getSourceClusterIdBytes in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The bytes for sourceClusterId.

      • getRowKey

        public com.google.protobuf.ByteString getRowKey()
         The row key for all mutations that are part of this `DataChange`.
 If the `DataChange` is chunked across multiple messages, then this field
 will only be set for the first message.
        bytes row_key = 3;
        Specified by:
        getRowKey in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The rowKey.

      • hasCommitTimestamp

        public boolean hasCommitTimestamp()
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;
        Specified by:
        hasCommitTimestamp in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        Whether the commitTimestamp field is set.

      • getCommitTimestamp

        public com.google.protobuf.Timestamp getCommitTimestamp()
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;
        Specified by:
        getCommitTimestamp in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The commitTimestamp.

      • getTiebreaker

        public int getTiebreaker()
         A value that lets stream consumers reconstruct Bigtable's
 conflict resolution semantics.
 https://cloud.google.com/bigtable/docs/writes#conflict-resolution
 In the event that the same row key, column family, column qualifier,
 timestamp are modified on different clusters at the same
 `commit_timestamp`, the mutation with the larger `tiebreaker` will be the
 one chosen for the eventually consistent state of the system.
        int32 tiebreaker = 5;
        Specified by:
        getTiebreaker in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The tiebreaker.

      • getChunksCount

        public int getChunksCount()
         The mutations associated with this change to the partition.
 May contain complete mutations or chunks of a multi-message chunked
 `DataChange` record.
        repeated .google.bigtable.v2.ReadChangeStreamResponse.MutationChunk chunks = 6;
        Specified by:
        getChunksCount in interface ReadChangeStreamResponse.DataChangeOrBuilder

      • getDone

        public boolean getDone()
         When true, indicates that the entire `DataChange` has been read
 and the client can safely process the message.
        bool done = 8;
        Specified by:
        getDone in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The done.

      • getTokenBytes

        public com.google.protobuf.ByteString getTokenBytes()
         An encoded position for this stream's partition to restart reading from.
 This token is for the StreamPartition from the request.
        string token = 9;
        Specified by:
        getTokenBytes in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The bytes for token.

      • hasEstimatedLowWatermark

        public boolean hasEstimatedLowWatermark()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 10;
        Specified by:
        hasEstimatedLowWatermark in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        Whether the estimatedLowWatermark field is set.

      • getEstimatedLowWatermark

        public com.google.protobuf.Timestamp getEstimatedLowWatermark()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 10;
        Specified by:
        getEstimatedLowWatermark in interface ReadChangeStreamResponse.DataChangeOrBuilder
        Returns:
        The estimatedLowWatermark.

      • getEstimatedLowWatermarkOrBuilder

        public com.google.protobuf.TimestampOrBuilder getEstimatedLowWatermarkOrBuilder()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 10;
        Specified by:
        getEstimatedLowWatermarkOrBuilder in interface ReadChangeStreamResponse.DataChangeOrBuilder

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessageV3

      • writeTo

        public void writeTo​(com.google.protobuf.CodedOutputStream output)
             throws IOException
        Specified by:
        writeTo in interface com.google.protobuf.MessageLite
        Overrides:
        writeTo in class com.google.protobuf.GeneratedMessageV3
        Throws:
        IOException

      • getSerializedSize

        public int getSerializedSize()
        Specified by:
        getSerializedSize in interface com.google.protobuf.MessageLite
        Overrides:
        getSerializedSize in class com.google.protobuf.GeneratedMessageV3

      • equals

        public boolean equals​(Object obj)
        Specified by:
        equals in interface com.google.protobuf.Message
        Overrides:
        equals in class com.google.protobuf.AbstractMessage

      • hashCode

        public int hashCode()
        Specified by:
        hashCode in interface com.google.protobuf.Message
        Overrides:
        hashCode in class com.google.protobuf.AbstractMessage

      • parseFrom

        public static ReadChangeStreamResponse.DataChange parseFrom​(ByteBuffer data,
                                                            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                     throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.DataChange parseFrom​(com.google.protobuf.ByteString data)
                                                     throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.DataChange 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.DataChange parseFrom​(byte[] data)
                                                     throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.DataChange parseFrom​(byte[] data,
                                                            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                     throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • newBuilderForType

        public ReadChangeStreamResponse.DataChange.Builder newBuilderForType()
        Specified by:
        newBuilderForType in interface com.google.protobuf.Message
        Specified by:
        newBuilderForType in interface com.google.protobuf.MessageLite

      • newBuilderForType

        protected ReadChangeStreamResponse.DataChange.Builder newBuilderForType​(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
        Specified by:
        newBuilderForType in class com.google.protobuf.GeneratedMessageV3

      • getParserForType

        public com.google.protobuf.Parser<ReadChangeStreamResponse.DataChange> getParserForType()
        Specified by:
        getParserForType in interface com.google.protobuf.Message
        Specified by:
        getParserForType in interface com.google.protobuf.MessageLite
        Overrides:
        getParserForType in class com.google.protobuf.GeneratedMessageV3

      • getDefaultInstanceForType

        public ReadChangeStreamResponse.DataChange getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder