Uses of Class
dev.frostlake.metastore.model.StreamRecord

Packages that use StreamRecord

Package	Description
dev.frostlake.metastore.model
dev.frostlake.transaction

Uses of StreamRecord in dev.frostlake.metastore.model

Methods in dev.frostlake.metastore.model that return types with arguments of type StreamRecord

Modifier and Type	Method	Description
List<StreamRecord>	Stream.getRecords()
List<StreamRecord>	Stream.getUnconsumedAppendsWith(List<StreamRecord> extraRaw)	The unconsumed records that APPENDED a row, in the order the appends happened, with the values each row was appended WITH — the append-only view of the change window.
List<StreamRecord>	Stream.getUnconsumedNetRecords()	The unconsumed change records consolidated to the NET delta per logical row, which is what a SELECT from a stream returns in Snowflake: a row inserted then updated inside the window is a single INSERT of its final image (ISUPDATE false); inserted then deleted cancels out entirely; a pre-existing row updated repeatedly nets to one DELETE(original)+INSERT(final) pair (ISUPDATE true); updated then deleted nets to a plain DELETE of the original image.
List<StreamRecord>	Stream.getUnconsumedNetRecordsWith(List<StreamRecord> extraRaw)	The net unconsumed records as Stream.getUnconsumedNetRecords(), but with extraRaw transient change records (e.g. the current transaction's not-yet-committed base-table changes) folded in AFTER the committed unconsumed ones, so a stream read inside a transaction reflects that transaction's own uncommitted DML — the deferred-apply equivalent of read-your-writes for streams.
List<StreamRecord>	Stream.getUnconsumedRecords()

Methods in dev.frostlake.metastore.model with parameters of type StreamRecord

Modifier and Type	Method	Description
void	Stream.addRecord(StreamRecord record)
static boolean	Stream.isAppend(StreamRecord record)	Whether a change record APPENDED a row: an INSERT that no UPDATE produced.

Method parameters in dev.frostlake.metastore.model with type arguments of type StreamRecord

Modifier and Type	Method	Description
void	Stream.consumeSeen(long committedCut, List<StreamRecord> seenTransient)	Consume exactly what a reader SAW, not everything present at commit: advance past the committed prefix visible at read time (committedCut records) and remove the records this transaction's commit re-emitted for changes that were already buffered when the read happened (seenTransient — matched by change kind, values and capture tag, at or after the cut).
List<StreamRecord>	Stream.getUnconsumedAppendsWith(List<StreamRecord> extraRaw)	The unconsumed records that APPENDED a row, in the order the appends happened, with the values each row was appended WITH — the append-only view of the change window.
List<StreamRecord>	Stream.getUnconsumedNetRecordsWith(List<StreamRecord> extraRaw)	The net unconsumed records as Stream.getUnconsumedNetRecords(), but with extraRaw transient change records (e.g. the current transaction's not-yet-committed base-table changes) folded in AFTER the committed unconsumed ones, so a stream read inside a transaction reflects that transaction's own uncommitted DML — the deferred-apply equivalent of read-your-writes for streams.

Uses of StreamRecord in dev.frostlake.transaction

Methods in dev.frostlake.transaction that return types with arguments of type StreamRecord

Modifier and Type	Method	Description
List<StreamRecord>	TransactionWriteSet.bufferedChangeRecords(String table, TableStorage base, String captureName)	Synthesize the stream change records for table's buffered (not-yet-committed) changes, exactly as TransactionWriteSet.applyTo(dev.frostlake.storage.StorageEngine) would track them at commit — an update as a DELETE(old)+INSERT(new) pair, a delete as a DELETE(old), an insert as an INSERT(new) — but WITHOUT mutating storage or any stream.
List<StreamRecord>	StreamReadScope.getSeenTransient()

Constructor parameters in dev.frostlake.transaction with type arguments of type StreamRecord

Modifier	Constructor	Description
	StreamReadScope(long committedCut, List<StreamRecord> seenTransient)