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

Packages that use Stream

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

Uses of Stream in dev.frostlake.metastore

Methods in dev.frostlake.metastore that return Stream

Modifier and Type	Method	Description
Stream	Catalog.resolveStream(String qualifiedName)	Resolve a stream by its (optionally schema- or db-qualified) name against the current context — SYSTEM$STREAM_HAS_DATA('SCHEMA.STREAM') passes the qualified text at runtime.

Uses of Stream in dev.frostlake.metastore.model

Methods in dev.frostlake.metastore.model that return Stream

Modifier and Type	Method	Description
Stream	Schema.getStream(String name)

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

Modifier and Type	Method	Description
List<Stream>	Schema.getStreams()

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

Modifier and Type	Method	Description
void	Schema.addStream(Stream stream)

Uses of Stream in dev.frostlake.stream

Methods in dev.frostlake.stream that return types with arguments of type Stream

Modifier and Type	Method	Description
List<Stream>	StreamManager.capturingStreams(String qualifiedTableName)	The streams capturing qualifiedTableName, resolved ONCE for a bulk apply — commit used to re-walk every schema's streams per committed ROW.

Methods in dev.frostlake.stream with parameters of type Stream

Modifier and Type	Method	Description
void	StreamManager.seedInitialRows(Stream stream, String qualifiedTableName, List<Row> rows)	Seed a freshly created SHOW_INITIAL_ROWS stream with the source table's existing rows as INSERT records, so the stream's first read returns the current table contents (Snowflake semantics).

Method parameters in dev.frostlake.stream with type arguments of type Stream

Modifier and Type	Method	Description
void	StreamManager.trackDelete(List<Stream> capturing, String qualifiedTableName, Row row)	StreamManager.trackDelete(String, Row) over a PRE-RESOLVED capture list (bulk commit apply).
void	StreamManager.trackInsert(List<Stream> capturing, String qualifiedTableName, Row row)	StreamManager.trackInsert(String, Row) over a PRE-RESOLVED capture list (bulk commit apply).
void	StreamManager.trackUpdate(List<Stream> capturing, String qualifiedTableName, Row oldRow, Row newRow)	StreamManager.trackUpdate(String, Row, Row) over a PRE-RESOLVED capture list (bulk commit apply).

Uses of Stream in dev.frostlake.transaction

Methods in dev.frostlake.transaction with parameters of type Stream

Modifier and Type	Method	Description
void	Transaction.registerStreamConsumption(Stream stream, StreamReadScope scope)	Register a stream read by a consuming DML in this txn; consumed on commit (scoped to what the read saw — see StreamReadScope), discarded on rollback.