Package dev.frostlake.persistence

Class StreamRecordSnapshot

java.lang.Object

dev.frostlake.persistence.StreamRecordSnapshot

All Implemented Interfaces:

Serializable

public class StreamRecordSnapshot
extends Object
implements Serializable

Serializable snapshot of a single change record buffered in a STREAM (the CDC tuple: row values, the change type, whether it came from an UPDATE, and the source row id).

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
String	changeType
long	rowId
String	sourceTable
boolean	update
List<Object>	values

Constructor Summary

Constructors

Constructor	Description
StreamRecordSnapshot()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

values

public List<Object> values

changeType

public String changeType

update

public boolean update

rowId

public long rowId

sourceTable

public String sourceTable

Constructor Details

StreamRecordSnapshot

public StreamRecordSnapshot()