Class DataChangeRecord (6.68.0)

public final class DataChangeRecord extends GeneratedMessageV3 implements DataChangeRecordOrBuilder

ChangeStream data change record.

Protobuf type google.spanner.executor.v1.DataChangeRecord

Static Fields

COLUMN_TYPES_FIELD_NUMBER

public static final int COLUMN_TYPES_FIELD_NUMBER
Field Value
Type Description
int

COMMIT_TIME_FIELD_NUMBER

public static final int COMMIT_TIME_FIELD_NUMBER
Field Value
Type Description
int

IS_LAST_RECORD_FIELD_NUMBER

public static final int IS_LAST_RECORD_FIELD_NUMBER
Field Value
Type Description
int

IS_SYSTEM_TRANSACTION_FIELD_NUMBER

public static final int IS_SYSTEM_TRANSACTION_FIELD_NUMBER
Field Value
Type Description
int

MODS_FIELD_NUMBER

public static final int MODS_FIELD_NUMBER
Field Value
Type Description
int

MOD_TYPE_FIELD_NUMBER

public static final int MOD_TYPE_FIELD_NUMBER
Field Value
Type Description
int

PARTITION_COUNT_FIELD_NUMBER

public static final int PARTITION_COUNT_FIELD_NUMBER
Field Value
Type Description
int

RECORD_COUNT_FIELD_NUMBER

public static final int RECORD_COUNT_FIELD_NUMBER
Field Value
Type Description
int

RECORD_SEQUENCE_FIELD_NUMBER

public static final int RECORD_SEQUENCE_FIELD_NUMBER
Field Value
Type Description
int

TABLE_FIELD_NUMBER

public static final int TABLE_FIELD_NUMBER
Field Value
Type Description
int

TRANSACTION_ID_FIELD_NUMBER

public static final int TRANSACTION_ID_FIELD_NUMBER
Field Value
Type Description
int

TRANSACTION_TAG_FIELD_NUMBER

public static final int TRANSACTION_TAG_FIELD_NUMBER
Field Value
Type Description
int

VALUE_CAPTURE_TYPE_FIELD_NUMBER

public static final int VALUE_CAPTURE_TYPE_FIELD_NUMBER
Field Value
Type Description
int

Static Methods

getDefaultInstance()

public static DataChangeRecord getDefaultInstance()
Returns
Type Description
DataChangeRecord

getDescriptor()

public static final Descriptors.Descriptor getDescriptor()
Returns
Type Description
Descriptor

newBuilder()

public static DataChangeRecord.Builder newBuilder()
Returns
Type Description
DataChangeRecord.Builder

newBuilder(DataChangeRecord prototype)

public static DataChangeRecord.Builder newBuilder(DataChangeRecord prototype)
Parameter
Name Description
prototype DataChangeRecord
Returns
Type Description
DataChangeRecord.Builder

parseDelimitedFrom(InputStream input)

public static DataChangeRecord parseDelimitedFrom(InputStream input)
Parameter
Name Description
input InputStream
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input InputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseFrom(byte[] data)

public static DataChangeRecord parseFrom(byte[] data)
Parameter
Name Description
data byte[]
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data byte[]
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteString data)

public static DataChangeRecord parseFrom(ByteString data)
Parameter
Name Description
data ByteString
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data ByteString
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(CodedInputStream input)

public static DataChangeRecord parseFrom(CodedInputStream input)
Parameter
Name Description
input CodedInputStream
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input CodedInputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseFrom(InputStream input)

public static DataChangeRecord parseFrom(InputStream input)
Parameter
Name Description
input InputStream
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
input InputStream
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
IOException

parseFrom(ByteBuffer data)

public static DataChangeRecord parseFrom(ByteBuffer data)
Parameter
Name Description
data ByteBuffer
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)

public static DataChangeRecord parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
Parameters
Name Description
data ByteBuffer
extensionRegistry ExtensionRegistryLite
Returns
Type Description
DataChangeRecord
Exceptions
Type Description
InvalidProtocolBufferException

parser()

public static Parser<DataChangeRecord> parser()
Returns
Type Description
Parser<DataChangeRecord>

Methods

equals(Object obj)

public boolean equals(Object obj)
Parameter
Name Description
obj Object
Returns
Type Description
boolean
Overrides

getColumnTypes(int index)

public DataChangeRecord.ColumnType getColumnTypes(int index)

Column types defined in the schema.

repeated .google.spanner.executor.v1.DataChangeRecord.ColumnType column_types = 6;

Parameter
Name Description
index int
Returns
Type Description
DataChangeRecord.ColumnType

getColumnTypesCount()

public int getColumnTypesCount()

Column types defined in the schema.

repeated .google.spanner.executor.v1.DataChangeRecord.ColumnType column_types = 6;

Returns
Type Description
int

getColumnTypesList()

public List<DataChangeRecord.ColumnType> getColumnTypesList()

Column types defined in the schema.

repeated .google.spanner.executor.v1.DataChangeRecord.ColumnType column_types = 6;

Returns
Type Description
List<ColumnType>

getColumnTypesOrBuilder(int index)

public DataChangeRecord.ColumnTypeOrBuilder getColumnTypesOrBuilder(int index)

Column types defined in the schema.

repeated .google.spanner.executor.v1.DataChangeRecord.ColumnType column_types = 6;

Parameter
Name Description
index int
Returns
Type Description
DataChangeRecord.ColumnTypeOrBuilder

getColumnTypesOrBuilderList()

public List<? extends DataChangeRecord.ColumnTypeOrBuilder> getColumnTypesOrBuilderList()

Column types defined in the schema.

repeated .google.spanner.executor.v1.DataChangeRecord.ColumnType column_types = 6;

Returns
Type Description
List<? extends com.google.spanner.executor.v1.DataChangeRecord.ColumnTypeOrBuilder>

getCommitTime()

public Timestamp getCommitTime()

The timestamp in which the change was committed.

.google.protobuf.Timestamp commit_time = 1;

Returns
Type Description
Timestamp

The commitTime.

getCommitTimeOrBuilder()

public TimestampOrBuilder getCommitTimeOrBuilder()

The timestamp in which the change was committed.

.google.protobuf.Timestamp commit_time = 1;

Returns
Type Description
TimestampOrBuilder

getDefaultInstanceForType()

public DataChangeRecord getDefaultInstanceForType()
Returns
Type Description
DataChangeRecord

getIsLastRecord()

public boolean getIsLastRecord()

Indicates whether this is the last record for a transaction in the current partition.

bool is_last_record = 4;

Returns
Type Description
boolean

The isLastRecord.

getIsSystemTransaction()

public boolean getIsSystemTransaction()

Whether the transaction is a system transactionn.

bool is_system_transaction = 13;

Returns
Type Description
boolean

The isSystemTransaction.

getModType()

public String getModType()

Describes the type of change. One of INSERT, UPDATE or DELETE.

string mod_type = 8;

Returns
Type Description
String

The modType.

getModTypeBytes()

public ByteString getModTypeBytes()

Describes the type of change. One of INSERT, UPDATE or DELETE.

string mod_type = 8;

Returns
Type Description
ByteString

The bytes for modType.

getMods(int index)

public DataChangeRecord.Mod getMods(int index)

Changes made in the transaction.

repeated .google.spanner.executor.v1.DataChangeRecord.Mod mods = 7;

Parameter
Name Description
index int
Returns
Type Description
DataChangeRecord.Mod

getModsCount()

public int getModsCount()

Changes made in the transaction.

repeated .google.spanner.executor.v1.DataChangeRecord.Mod mods = 7;

Returns
Type Description
int

getModsList()

public List<DataChangeRecord.Mod> getModsList()

Changes made in the transaction.

repeated .google.spanner.executor.v1.DataChangeRecord.Mod mods = 7;

Returns
Type Description
List<Mod>

getModsOrBuilder(int index)

public DataChangeRecord.ModOrBuilder getModsOrBuilder(int index)

Changes made in the transaction.

repeated .google.spanner.executor.v1.DataChangeRecord.Mod mods = 7;

Parameter
Name Description
index int
Returns
Type Description
DataChangeRecord.ModOrBuilder

getModsOrBuilderList()

public List<? extends DataChangeRecord.ModOrBuilder> getModsOrBuilderList()

Changes made in the transaction.

repeated .google.spanner.executor.v1.DataChangeRecord.Mod mods = 7;

Returns
Type Description
List<? extends com.google.spanner.executor.v1.DataChangeRecord.ModOrBuilder>

getParserForType()

public Parser<DataChangeRecord> getParserForType()
Returns
Type Description
Parser<DataChangeRecord>
Overrides

getPartitionCount()

public long getPartitionCount()

Number of partitions in transactions.

int64 partition_count = 11;

Returns
Type Description
long

The partitionCount.

getRecordCount()

public long getRecordCount()

Number of records in transactions.

int64 record_count = 10;

Returns
Type Description
long

The recordCount.

getRecordSequence()

public String getRecordSequence()

The sequence number for the record within the transaction.

string record_sequence = 2;

Returns
Type Description
String

The recordSequence.

getRecordSequenceBytes()

public ByteString getRecordSequenceBytes()

The sequence number for the record within the transaction.

string record_sequence = 2;

Returns
Type Description
ByteString

The bytes for recordSequence.

getSerializedSize()

public int getSerializedSize()
Returns
Type Description
int
Overrides

getTable()

public String getTable()

Name of the table affected by the change.

string table = 5;

Returns
Type Description
String

The table.

getTableBytes()

public ByteString getTableBytes()

Name of the table affected by the change.

string table = 5;

Returns
Type Description
ByteString

The bytes for table.

getTransactionId()

public String getTransactionId()

A globally unique string that represents the transaction in which the change was committed.

string transaction_id = 3;

Returns
Type Description
String

The transactionId.

getTransactionIdBytes()

public ByteString getTransactionIdBytes()

A globally unique string that represents the transaction in which the change was committed.

string transaction_id = 3;

Returns
Type Description
ByteString

The bytes for transactionId.

getTransactionTag()

public String getTransactionTag()

Transaction tag info.

string transaction_tag = 12;

Returns
Type Description
String

The transactionTag.

getTransactionTagBytes()

public ByteString getTransactionTagBytes()

Transaction tag info.

string transaction_tag = 12;

Returns
Type Description
ByteString

The bytes for transactionTag.

getValueCaptureType()

public String getValueCaptureType()

One of value capture type: NEW_VALUES, OLD_VALUES, OLD_AND_NEW_VALUES.

string value_capture_type = 9;

Returns
Type Description
String

The valueCaptureType.

getValueCaptureTypeBytes()

public ByteString getValueCaptureTypeBytes()

One of value capture type: NEW_VALUES, OLD_VALUES, OLD_AND_NEW_VALUES.

string value_capture_type = 9;

Returns
Type Description
ByteString

The bytes for valueCaptureType.

hasCommitTime()

public boolean hasCommitTime()

The timestamp in which the change was committed.

.google.protobuf.Timestamp commit_time = 1;

Returns
Type Description
boolean

Whether the commitTime field is set.

hashCode()

public int hashCode()
Returns
Type Description
int
Overrides

internalGetFieldAccessorTable()

protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Returns
Type Description
FieldAccessorTable
Overrides

isInitialized()

public final boolean isInitialized()
Returns
Type Description
boolean
Overrides

newBuilderForType()

public DataChangeRecord.Builder newBuilderForType()
Returns
Type Description
DataChangeRecord.Builder

newBuilderForType(GeneratedMessageV3.BuilderParent parent)

protected DataChangeRecord.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Parameter
Name Description
parent BuilderParent
Returns
Type Description
DataChangeRecord.Builder
Overrides

newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)

protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Parameter
Name Description
unused UnusedPrivateParameter
Returns
Type Description
Object
Overrides

toBuilder()

public DataChangeRecord.Builder toBuilder()
Returns
Type Description
DataChangeRecord.Builder

writeTo(CodedOutputStream output)

public void writeTo(CodedOutputStream output)
Parameter
Name Description
output CodedOutputStream
Overrides
Exceptions
Type Description
IOException