public sealed class ReadChangeStreamResponse.Types.DataChange : IMessage<ReadChangeStreamResponse.Types.DataChange>, IEquatable<ReadChangeStreamResponse.Types.DataChange>, IDeepCloneable<ReadChangeStreamResponse.Types.DataChange>, IBufferMessage, IMessageReference 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.
Implements
IMessageReadChangeStreamResponseTypesDataChange, IEquatableReadChangeStreamResponseTypesDataChange, IDeepCloneableReadChangeStreamResponseTypesDataChange, IBufferMessage, IMessageNamespace
GoogleGoogle.CloudGoogle.Cloud.BigtableV2Assembly
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 is 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 | |