Package dev.frostlake.persistence

Class StreamSnapshot

java.lang.Object

dev.frostlake.persistence.StreamSnapshot

All Implemented Interfaces:

Serializable

public class StreamSnapshot
extends Object
implements Serializable

Serializable snapshot of a STREAM — its definition plus the pending (unconsumed) change records, which are restored at offset 0 so consuming after a reload yields the same rows. Already-consumed history is intentionally dropped (it has no effect on future reads).

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
String	baseTableName
List<String>	baseTableNames
String	comment
String	name
String	owner
List<StreamRecordSnapshot>	records
boolean	showInitialRows
String	sourceTableName
String	sourceType
boolean	stale
String	streamType

Constructor Summary

Constructors

Constructor	Description
StreamSnapshot()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

name

public String name

sourceTableName

public String sourceTableName

baseTableName

public String baseTableName

baseTableNames

public List<String> baseTableNames

sourceType

public String sourceType

streamType

public String streamType

showInitialRows

public boolean showInitialRows

stale

public boolean stale

comment

public String comment

owner

public String owner

records

public List<StreamRecordSnapshot> records

Constructor Details

StreamSnapshot

public StreamSnapshot()