Package dev.frostlake.metastore.model

Class StreamNetChange

java.lang.Object

dev.frostlake.metastore.model.StreamNetChange

public class StreamNetChange
extends Object

One logical row's accumulated (net) change while consolidating a stream window: oldValues is the row's image at the stream offset (null when the row was born inside the window) and newValues its current image (null when the row no longer exists). Both null means the change cancelled out entirely.

Constructor Summary

Constructors

Constructor	Description
StreamNetChange(List<Object> oldValues, List<Object> newValues, long rowId)
StreamNetChange(List<Object> oldValues, List<Object> newValues, long rowId, String sourceTable)

Method Summary

Modifier and Type	Method	Description
List<Object>	getNewValues()
List<Object>	getOldValues()
long	getRowId()
String	getSourceTable()	Bare (upper-case) base table this net change was captured from; null for single-source streams.
void	setNewValues(List<Object> newValues)	Advance the row's current image (a later update in the window), or null it out (a delete).

Methods inherited from class java.lang.Object

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

Constructor Details

StreamNetChange

public StreamNetChange(List<Object> oldValues,
 List<Object> newValues,
 long rowId)

StreamNetChange

public StreamNetChange(List<Object> oldValues,
 List<Object> newValues,
 long rowId,
 String sourceTable)

Method Details

getOldValues

public List<Object> getOldValues()

getNewValues

public List<Object> getNewValues()

setNewValues

public void setNewValues(List<Object> newValues)

Advance the row's current image (a later update in the window), or null it out (a delete).

getRowId

public long getRowId()

getSourceTable

public String getSourceTable()

Bare (upper-case) base table this net change was captured from; null for single-source streams.