Package com.google.bigtable.v2

Class ReadChangeStreamResponse.DataChange.Builder

  • All Implemented Interfaces:
    ReadChangeStreamResponse.DataChangeOrBuilder, com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable
    Enclosing class:
    ReadChangeStreamResponse.DataChange
    public static final class ReadChangeStreamResponse.DataChange.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.DataChange.Builder>
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

    • Method Detail

      • 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.Builder<ReadChangeStreamResponse.DataChange.Builder>

      • getDescriptorForType

        public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
        Specified by:
        getDescriptorForType in interface com.google.protobuf.Message.Builder
        Specified by:
        getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
        Overrides:
        getDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.DataChange.Builder>

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<ReadChangeStreamResponse.DataChange.Builder>

      • 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.

      • setTypeValue

        public ReadChangeStreamResponse.DataChange.Builder setTypeValue​(int value)
         The type of the mutation.
        .google.bigtable.v2.ReadChangeStreamResponse.DataChange.Type type = 1;
        Parameters:
        value - The enum numeric value on the wire for type to set.
        Returns:
        This builder for chaining.

      • 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.

      • setSourceClusterId

        public ReadChangeStreamResponse.DataChange.Builder setSourceClusterId​(String value)
         The cluster where the mutation was applied.
 Not set when `type` is `GARBAGE_COLLECTION`.
        string source_cluster_id = 2;
        Parameters:
        value - The sourceClusterId to set.
        Returns:
        This builder for chaining.

      • clearSourceClusterId

        public ReadChangeStreamResponse.DataChange.Builder clearSourceClusterId()
         The cluster where the mutation was applied.
 Not set when `type` is `GARBAGE_COLLECTION`.
        string source_cluster_id = 2;
        Returns:
        This builder for chaining.

      • setSourceClusterIdBytes

        public ReadChangeStreamResponse.DataChange.Builder setSourceClusterIdBytes​(com.google.protobuf.ByteString value)
         The cluster where the mutation was applied.
 Not set when `type` is `GARBAGE_COLLECTION`.
        string source_cluster_id = 2;
        Parameters:
        value - The bytes for sourceClusterId to set.
        Returns:
        This builder for chaining.

      • 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.

      • setRowKey

        public ReadChangeStreamResponse.DataChange.Builder setRowKey​(com.google.protobuf.ByteString value)
         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;
        Parameters:
        value - The rowKey to set.
        Returns:
        This builder for chaining.

      • clearRowKey

        public ReadChangeStreamResponse.DataChange.Builder clearRowKey()
         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;
        Returns:
        This builder for chaining.

      • 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.

      • setCommitTimestamp

        public ReadChangeStreamResponse.DataChange.Builder setCommitTimestamp​(com.google.protobuf.Timestamp value)
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;

      • setCommitTimestamp

        public ReadChangeStreamResponse.DataChange.Builder setCommitTimestamp​(com.google.protobuf.Timestamp.Builder builderForValue)
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;

      • mergeCommitTimestamp

        public ReadChangeStreamResponse.DataChange.Builder mergeCommitTimestamp​(com.google.protobuf.Timestamp value)
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;

      • clearCommitTimestamp

        public ReadChangeStreamResponse.DataChange.Builder clearCommitTimestamp()
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;

      • getCommitTimestampBuilder

        public com.google.protobuf.Timestamp.Builder getCommitTimestampBuilder()
         The timestamp at which the mutation was applied on the Bigtable server.
        .google.protobuf.Timestamp commit_timestamp = 4;

      • 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.

      • setTiebreaker

        public ReadChangeStreamResponse.DataChange.Builder setTiebreaker​(int value)
         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;
        Parameters:
        value - The tiebreaker to set.
        Returns:
        This builder for chaining.

      • clearTiebreaker

        public ReadChangeStreamResponse.DataChange.Builder clearTiebreaker()
         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;
        Returns:
        This builder for chaining.

      • 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

      • clearChunks

        public ReadChangeStreamResponse.DataChange.Builder clearChunks()
         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;

      • removeChunks

        public ReadChangeStreamResponse.DataChange.Builder removeChunks​(int index)
         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;

      • getChunksBuilder

        public ReadChangeStreamResponse.MutationChunk.Builder getChunksBuilder​(int index)
         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;

      • addChunksBuilder

        public ReadChangeStreamResponse.MutationChunk.Builder addChunksBuilder()
         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;

      • addChunksBuilder

        public ReadChangeStreamResponse.MutationChunk.Builder addChunksBuilder​(int index)
         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;

      • getChunksBuilderList

        public List<ReadChangeStreamResponse.MutationChunk.Builder> getChunksBuilderList()
         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;

      • 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.

      • setDone

        public ReadChangeStreamResponse.DataChange.Builder setDone​(boolean value)
         When true, indicates that the entire `DataChange` has been read
 and the client can safely process the message.
        bool done = 8;
        Parameters:
        value - The done to set.
        Returns:
        This builder for chaining.

      • clearDone

        public ReadChangeStreamResponse.DataChange.Builder clearDone()
         When true, indicates that the entire `DataChange` has been read
 and the client can safely process the message.
        bool done = 8;
        Returns:
        This builder for chaining.

      • 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.

      • setToken

        public ReadChangeStreamResponse.DataChange.Builder setToken​(String value)
         An encoded position for this stream's partition to restart reading from.
 This token is for the StreamPartition from the request.
        string token = 9;
        Parameters:
        value - The token to set.
        Returns:
        This builder for chaining.

      • clearToken

        public ReadChangeStreamResponse.DataChange.Builder clearToken()
         An encoded position for this stream's partition to restart reading from.
 This token is for the StreamPartition from the request.
        string token = 9;
        Returns:
        This builder for chaining.

      • setTokenBytes

        public ReadChangeStreamResponse.DataChange.Builder setTokenBytes​(com.google.protobuf.ByteString value)
         An encoded position for this stream's partition to restart reading from.
 This token is for the StreamPartition from the request.
        string token = 9;
        Parameters:
        value - The bytes for token to set.
        Returns:
        This builder for chaining.

      • 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.

      • setEstimatedLowWatermark

        public ReadChangeStreamResponse.DataChange.Builder setEstimatedLowWatermark​(com.google.protobuf.Timestamp value)
         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;

      • setEstimatedLowWatermark

        public ReadChangeStreamResponse.DataChange.Builder setEstimatedLowWatermark​(com.google.protobuf.Timestamp.Builder builderForValue)
         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;

      • mergeEstimatedLowWatermark

        public ReadChangeStreamResponse.DataChange.Builder mergeEstimatedLowWatermark​(com.google.protobuf.Timestamp value)
         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;

      • clearEstimatedLowWatermark

        public ReadChangeStreamResponse.DataChange.Builder clearEstimatedLowWatermark()
         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;

      • getEstimatedLowWatermarkBuilder

        public com.google.protobuf.Timestamp.Builder getEstimatedLowWatermarkBuilder()
         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;

      • 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