Cloud Bigtable V2 API - Class Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::DataChange (v1.10.0)

Reference documentation and code samples for the Cloud Bigtable V2 API class Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::DataChange.

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.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#chunks

def chunks() -> ::Array<::Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::MutationChunk>
Returns

#chunks=

def chunks=(value) -> ::Array<::Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::MutationChunk>
Parameter
Returns

#commit_timestamp

def commit_timestamp() -> ::Google::Protobuf::Timestamp
Returns

#commit_timestamp=

def commit_timestamp=(value) -> ::Google::Protobuf::Timestamp
Parameter
Returns

#done

def done() -> ::Boolean
Returns
  • (::Boolean) — When true, indicates that the entire DataChange has been read and the client can safely process the message.

#done=

def done=(value) -> ::Boolean
Parameter
  • value (::Boolean) — When true, indicates that the entire DataChange has been read and the client can safely process the message.
Returns
  • (::Boolean) — When true, indicates that the entire DataChange has been read and the client can safely process the message.

#estimated_low_watermark

def estimated_low_watermark() -> ::Google::Protobuf::Timestamp
Returns
  • (::Google::Protobuf::Timestamp) — 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 that is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks

#estimated_low_watermark=

def estimated_low_watermark=(value) -> ::Google::Protobuf::Timestamp
Parameter
  • value (::Google::Protobuf::Timestamp) — 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 that is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks
Returns
  • (::Google::Protobuf::Timestamp) — 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 that is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks

#row_key

def row_key() -> ::String
Returns
  • (::String) — 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.

#row_key=

def row_key=(value) -> ::String
Parameter
  • value (::String) — 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.
Returns
  • (::String) — 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.

#source_cluster_id

def source_cluster_id() -> ::String
Returns
  • (::String) — The cluster where the mutation was applied. Not set when type is GARBAGE_COLLECTION.

#source_cluster_id=

def source_cluster_id=(value) -> ::String
Parameter
  • value (::String) — The cluster where the mutation was applied. Not set when type is GARBAGE_COLLECTION.
Returns
  • (::String) — The cluster where the mutation was applied. Not set when type is GARBAGE_COLLECTION.

#tiebreaker

def tiebreaker() -> ::Integer
Returns
  • (::Integer) — 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.

#tiebreaker=

def tiebreaker=(value) -> ::Integer
Parameter
  • value (::Integer) — 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.
Returns
  • (::Integer) — 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.

#token

def token() -> ::String
Returns
  • (::String) — An encoded position for this stream's partition to restart reading from. This token is for the StreamPartition from the request.

#token=

def token=(value) -> ::String
Parameter
  • value (::String) — An encoded position for this stream's partition to restart reading from. This token is for the StreamPartition from the request.
Returns
  • (::String) — An encoded position for this stream's partition to restart reading from. This token is for the StreamPartition from the request.

#type

def type() -> ::Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::DataChange::Type
Returns

#type=

def type=(value) -> ::Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::DataChange::Type
Parameter
Returns