Package dev.frostlake.metastore.model

Class StreamRecord

java.lang.Object

dev.frostlake.metastore.model.StreamRecord

public class StreamRecord
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamRecord(List<Object> values, ChangeType changeType, boolean isUpdate, long rowId)
StreamRecord(List<Object> values, ChangeType changeType, boolean isUpdate, long rowId, String sourceTable)

Method Summary

Modifier and Type	Method	Description
ChangeType	getChangeType()
long	getRowId()
String	getSourceTable()	Bare (upper-case) name of the base table this change was captured from.
LocalDateTime	getTimestamp()
List<Object>	getValues()
boolean	isUpdate()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamRecord

public StreamRecord(List<Object> values,
 ChangeType changeType,
 boolean isUpdate,
 long rowId)

StreamRecord

public StreamRecord(List<Object> values,
 ChangeType changeType,
 boolean isUpdate,
 long rowId,
 String sourceTable)

Method Details

getValues

public List<Object> getValues()

getChangeType

public ChangeType getChangeType()

isUpdate

public boolean isUpdate()

getRowId

public long getRowId()

getTimestamp

public LocalDateTime getTimestamp()

getSourceTable

public String getSourceTable()

Bare (upper-case) name of the base table this change was captured from. Used to route records to the matching branch of a UNION ALL view stream; null for table streams and single-branch views.