Interface ReadChangeStreamResponse.DataChangeOrBuilder

    • Method Detail

      • getTypeValue

        int getTypeValue()
         The type of the mutation.
         
        .google.bigtable.v2.ReadChangeStreamResponse.DataChange.Type type = 1;
        Returns:
        The enum numeric value on the wire for type.
      • getSourceClusterId

        String getSourceClusterId()
         The cluster where the mutation was applied.
         Not set when `type` is `GARBAGE_COLLECTION`.
         
        string source_cluster_id = 2;
        Returns:
        The sourceClusterId.
      • getSourceClusterIdBytes

        com.google.protobuf.ByteString getSourceClusterIdBytes()
         The cluster where the mutation was applied.
         Not set when `type` is `GARBAGE_COLLECTION`.
         
        string source_cluster_id = 2;
        Returns:
        The bytes for sourceClusterId.
      • getRowKey

        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;
        Returns:
        The rowKey.
      • hasCommitTimestamp

        boolean hasCommitTimestamp()
         The timestamp at which the mutation was applied on the Bigtable server.
         
        .google.protobuf.Timestamp commit_timestamp = 4;
        Returns:
        Whether the commitTimestamp field is set.
      • getCommitTimestamp

        com.google.protobuf.Timestamp getCommitTimestamp()
         The timestamp at which the mutation was applied on the Bigtable server.
         
        .google.protobuf.Timestamp commit_timestamp = 4;
        Returns:
        The commitTimestamp.
      • getCommitTimestampOrBuilder

        com.google.protobuf.TimestampOrBuilder getCommitTimestampOrBuilder()
         The timestamp at which the mutation was applied on the Bigtable server.
         
        .google.protobuf.Timestamp commit_timestamp = 4;
      • getTiebreaker

        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;
        Returns:
        The tiebreaker.
      • getChunksList

        List<ReadChangeStreamResponse.MutationChunk> getChunksList()
         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;
      • getChunks

        ReadChangeStreamResponse.MutationChunk getChunks​(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;
      • getChunksCount

        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;
      • getChunksOrBuilderList

        List<? extends ReadChangeStreamResponse.MutationChunkOrBuilder> getChunksOrBuilderList()
         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;
      • getChunksOrBuilder

        ReadChangeStreamResponse.MutationChunkOrBuilder getChunksOrBuilder​(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;
      • getDone

        boolean getDone()
         When true, indicates that the entire `DataChange` has been read
         and the client can safely process the message.
         
        bool done = 8;
        Returns:
        The done.
      • getToken

        String getToken()
         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:
        The token.
      • getTokenBytes

        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;
        Returns:
        The bytes for token.
      • hasEstimatedLowWatermark

        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;
        Returns:
        Whether the estimatedLowWatermark field is set.
      • getEstimatedLowWatermark

        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;
        Returns:
        The estimatedLowWatermark.
      • getEstimatedLowWatermarkOrBuilder

        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;