Google Bigtable v2 API - Class ReadChangeStreamResponse.Types.DataChange (3.24.0) 

public sealed class ReadChangeStreamResponse.Types.DataChange : IMessage<ReadChangeStreamResponse.Types.DataChange>, IEquatable<ReadChangeStreamResponse.Types.DataChange>, IDeepCloneable<ReadChangeStreamResponse.Types.DataChange>, IBufferMessage, IMessage

Reference documentation and code samples for the Google Bigtable v2 API class ReadChangeStreamResponse.Types.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.

Inheritance

object > ReadChangeStreamResponse.Types.DataChange

Namespace

Google.Cloud.Bigtable.V2

Assembly

Google.Cloud.Bigtable.V2.dll

Constructors

DataChange()

public DataChange()

DataChange(DataChange)

public DataChange(ReadChangeStreamResponse.Types.DataChange other)
Parameter
Name Description
other ReadChangeStreamResponseTypesDataChange

Properties

Chunks

public RepeatedField<ReadChangeStreamResponse.Types.MutationChunk> Chunks { get; }

The mutations associated with this change to the partition. May contain complete mutations or chunks of a multi-message chunked DataChange record.

Property Value
Type Description
RepeatedFieldReadChangeStreamResponseTypesMutationChunk

CommitTimestamp

public Timestamp CommitTimestamp { get; set; }

The timestamp at which the mutation was applied on the Bigtable server.

Property Value
Type Description
Timestamp

Done

public bool Done { get; set; }

When true, indicates that the entire DataChange has been read and the client can safely process the message.

Property Value
Type Description
bool

EstimatedLowWatermark

public Timestamp EstimatedLowWatermark { get; set; }

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

Property Value
Type Description
Timestamp

RowKey

public ByteString RowKey { get; set; }

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.

Property Value
Type Description
ByteString

SourceClusterId

public string SourceClusterId { get; set; }

The cluster where the mutation was applied. Not set when type is GARBAGE_COLLECTION.

Property Value
Type Description
string

Tiebreaker

public int Tiebreaker { get; set; }

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.

Property Value
Type Description
int

Token

public string Token { get; set; }

An encoded position for this stream's partition to restart reading from. This token is for the StreamPartition from the request.

Property Value
Type Description
string

Type

public ReadChangeStreamResponse.Types.DataChange.Types.Type Type { get; set; }

The type of the mutation.

Property Value
Type Description
ReadChangeStreamResponseTypesDataChangeTypesType