Package com.google.bigtable.v2

Interface ReadChangeStreamResponse.DataChangeOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
ReadChangeStreamResponse.DataChange, ReadChangeStreamResponse.DataChange.Builder
Enclosing class:
ReadChangeStreamResponse
public static interface ReadChangeStreamResponse.DataChangeOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Summary

    Modifier and Type
    Method
    Description
    ReadChangeStreamResponse.MutationChunk
    getChunks(int index)
    The mutations associated with this change to the partition.
    int
    getChunksCount()
    The mutations associated with this change to the partition.
    List<ReadChangeStreamResponse.MutationChunk>
    getChunksList()
    The mutations associated with this change to the partition.
    ReadChangeStreamResponse.MutationChunkOrBuilder
    getChunksOrBuilder(int index)
    The mutations associated with this change to the partition.
    List<? extends ReadChangeStreamResponse.MutationChunkOrBuilder>
    getChunksOrBuilderList()
    The mutations associated with this change to the partition.
    com.google.protobuf.Timestamp
    getCommitTimestamp()
    The timestamp at which the mutation was applied on the Bigtable server.
    com.google.protobuf.TimestampOrBuilder
    getCommitTimestampOrBuilder()
    The timestamp at which the mutation was applied on the Bigtable server.
    boolean
    getDone()
    When true, indicates that the entire `DataChange` has been read and the client can safely process the message.
    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.
    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.
    com.google.protobuf.ByteString
    getRowKey()
    The row key for all mutations that are part of this `DataChange`.
    String
    getSourceClusterId()
    The cluster where the mutation was applied.
    com.google.protobuf.ByteString
    getSourceClusterIdBytes()
    The cluster where the mutation was applied.
    int
    getTiebreaker()
    A value that lets stream consumers reconstruct Bigtable's conflict resolution semantics.
    String
    getToken()
    An encoded position for this stream's partition to restart reading from.
    com.google.protobuf.ByteString
    getTokenBytes()
    An encoded position for this stream's partition to restart reading from.
    ReadChangeStreamResponse.DataChange.Type
    getType()
    The type of the mutation.
    int
    getTypeValue()
    The type of the mutation.
    boolean
    hasCommitTimestamp()
    The timestamp at which the mutation was applied on the Bigtable server.
    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.

    Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

    isInitialized

    Methods inherited from interface com.google.protobuf.MessageOrBuilder

    findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

  • Method Details

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

    • getType

      ReadChangeStreamResponse.DataChange.Type getType()
       The type of the mutation.
      .google.bigtable.v2.ReadChangeStreamResponse.DataChange.Type type = 1;
      Returns:
      The 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;