Cloud Bigtable V2 API - Class Google::Cloud::Bigtable::V2::ReadChangeStreamResponse::Heartbeat (v0.17.2)

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

A periodic message with information that can be used to checkpoint the state of a stream.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#continuation_token

def continuation_token() -> ::Google::Cloud::Bigtable::V2::StreamContinuationToken
Returns

#continuation_token=

def continuation_token=(value) -> ::Google::Cloud::Bigtable::V2::StreamContinuationToken
Parameter
Returns

#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 is 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 is 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 is is lower than a previously seen timestamp. For an example usage see https://beam.apache.org/documentation/basics/#watermarks