Uses of Class
dev.frostlake.storage.Row

Packages that use Row

Package	Description
dev.frostlake.executor
dev.frostlake.executor.expressions
dev.frostlake.executor.operators
dev.frostlake.executor.procedural
dev.frostlake.executor.streaming
dev.frostlake.functions.window
dev.frostlake.metastore
dev.frostlake.storage
dev.frostlake.stream
dev.frostlake.transaction

Uses of Row in dev.frostlake.executor

Methods in dev.frostlake.executor that return types with arguments of type Row

Modifier and Type	Method	Description
static List<Row>	SetOperations.applyDistinct(List<Row> rows)	Apply DISTINCT to remove duplicate rows (first occurrence kept, order preserved) — O(n) via a hash set on normalized row keys.
static List<Row>	SetOperations.applyDistinct(List<Row> rows, CollationSpec[] collations)	Apply DISTINCT where some columns compare under a collation: values that differ only below the collation's strength are ONE row, and the row reports the smallest of them by raw text.
static List<Row>	SetOperations.applyExcept(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply EXCEPT operation.
static List<Row>	SetOperations.applyIntersect(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply INTERSECT operation.
static List<Row>	SetOperations.applyUnion(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply UNION operation.
static List<Row>	SetOperations.applyUnion(List<Row> leftRows, List<Row> rightRowsRaw, boolean all, List<ResultSetColumn> leadingColumns)	Apply UNION, with the LEADING branch's column layout available so an empty leading branch still types the union.
List<Row>	ConnectByExpander.expand(List<Row> baseRows, Table baseTable, Table expandedTable, FrostlakeParser.ConnectByClauseContext clause, Map<String,Table> aliasToTable, List<Table> allTables)	Expand baseRows into the hierarchy described by the clause, in depth-first pre-order (parent immediately before its subtree).

Methods in dev.frostlake.executor with parameters of type Row

Modifier and Type	Method	Description
void	QueryExecutor.coerceRowTypesLenient(Table table, Row row)	Lenient per-column coercion for CTAS rows: coerce each value to the created table's column type when the conversion works, and keep the ORIGINAL value when it does not.
Long	WindowPartitionOrder.denseRank(Row row)
void	QueryExecutor.enforceColumnConstraints(Table table, Row row)	Enforce column constraints at statement time on the COPY write path: coerce values to the column type (only when constraints.enforce.types is on), then check NOT NULL (always — Snowflake enforces NOT NULL, unlike the informational PK/UK/FK).
void	QueryExecutor.enforceColumnConstraintsForDml(Table table, Row row)	The DML flavour of QueryExecutor.enforceColumnConstraints(Table, Row): INSERT, INSERT … SELECT, UPDATE and MERGE all report a write violation inside a per-statement envelope naming the table and the column — live-verified verbatim, DML operation to table NN failed on column C with error: NULL result in a non-nullable column — around the same inner sentences the COPY path reports bare.
void	QueryExecutor.enforceColumnConstraintsForDml(Table table, Row row, boolean boundToColumnSlot)	QueryExecutor.enforceColumnConstraintsForDml(Table, Row, boolean, String) naming the table bare.
void	QueryExecutor.enforceColumnConstraintsForDml(Table table, Row row, boolean boundToColumnSlot, String writtenName)	The write-time constraints of one row, each failure wrapped in the DML envelope that names the table AS THE STATEMENT WROTE IT — TEST_DB.TEST_SCHEMA.TWO for a qualified INSERT, TWO for a bare one, four parts when the account was written (live-verified for INSERT, UPDATE, UPDATE … FROM and both MERGE branches).
Object	ExpressionEvaluator.evaluate(Expression expression, Row row)	Evaluate an expression AST against a row (RECOMMENDED) This method is more efficient than string-based evaluation because the expression is already parsed.
Object	ExpressionEvaluator.evaluate(String expression, Row row)	Evaluate a string expression against a row: parse it to an AST (cached) and evaluate via ExpressionEvaluatorVisitor.
Object	MergeRowShape.evaluate(String expr, Row targetRow, Row sourceRow)	Evaluate expr over the merged row for this pair (refills only the values list).
Long	WindowPartitionOrder.position(Row row)	1-based position of the first row equal to row, or null when no row equals it.
Long	WindowPartitionOrder.rank(Row row)
Object	QueryExecutor.resolveColumnInTables(Row row, List<Table> tables, Map<String,Table> aliasToTable, String qualifiedName)	Resolve a (possibly qualified) column reference against a multi-table row context — the alias-aware resolution used by JOIN evaluation, exposed for the AST evaluator so a parsed Expression can be evaluated directly over joined rows (e.g.
Object	QueryExecutor.resolveColumnInTables(Row row, List<Table> tables, Map<String,Table> aliasToTable, String qualifiedName, int[] resolvedOffset)	Resolve like QueryExecutor.resolveColumnInTables(Row, List, Map, String), additionally reporting HOW the reference resolved through resolvedOffset[0]: the flat row offset when the value came from the plain table-column scan (a fixed layout position the caller may cache for this context), left untouched when it resolved any other way (literal fallback, merged join key — per-row decisions that must re-run).
void	DeferredInsertGuard.validate(Row row)	Refuse row if it duplicates a primary key (in the committed base or this transaction's pending inserts) or a guarded UNIQUE column's non-null value; an accepted row's values join the seen sets so later rows of the same statement are checked against it too.
Object	GroupedExpressionValues.valueOf(Row projectedRow, String expressionText)	The expression's value for one grouped output row.
void	QueryExecutor.writeCtasRow(Table table, Row row, String envelopeName)	A CTAS row written into the declared types of its column list, as live writes it: each value is converted to its column the way an INSERT converts it — a number rounded to the scale, text parsed — and a value that does not fit is refused inside the DML envelope naming the table and the column ("DML operation to table DB.S.T failed on column X with error: String 'abcd' is too long and would be truncated").

Method parameters in dev.frostlake.executor with type arguments of type Row

Modifier and Type	Method	Description
static List<Row>	SetOperations.applyDistinct(List<Row> rows)	Apply DISTINCT to remove duplicate rows (first occurrence kept, order preserved) — O(n) via a hash set on normalized row keys.
static List<Row>	SetOperations.applyDistinct(List<Row> rows, CollationSpec[] collations)	Apply DISTINCT where some columns compare under a collation: values that differ only below the collation's strength are ONE row, and the row reports the smallest of them by raw text.
static List<Row>	SetOperations.applyExcept(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply EXCEPT operation.
static List<Row>	SetOperations.applyIntersect(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply INTERSECT operation.
static List<Row>	SetOperations.applyUnion(List<Row> leftRows, List<Row> rightRowsRaw, boolean all)	Apply UNION operation.
static List<Row>	SetOperations.applyUnion(List<Row> leftRows, List<Row> rightRowsRaw, boolean all, List<ResultSetColumn> leadingColumns)	Apply UNION, with the LEADING branch's column layout available so an empty leading branch still types the union.
static void	SetOperations.coerceStringBranches(List<List<Row>> branchRows, List<List<ResultSetColumn>> branchColumns, List<ResultSetColumn> unified)	Convert every branch's values toward the unified column types, in place in branchRows.
List<Row>	ConnectByExpander.expand(List<Row> baseRows, Table baseTable, Table expandedTable, FrostlakeParser.ConnectByClauseContext clause, Map<String,Table> aliasToTable, List<Table> allTables)	Expand baseRows into the hierarchy described by the clause, in depth-first pre-order (parent immediately before its subtree).

Constructor parameters in dev.frostlake.executor with type arguments of type Row

Modifier	Constructor	Description
	WindowPartitionOrder(Map<Row,Long> positionByRow, Map<Row,Long> rankByRow, Map<Row,Long> denseRankByRow, int[] firstPeerByIndex, int[] lastPeerByIndex)

Uses of Row in dev.frostlake.executor.expressions

Methods in dev.frostlake.executor.expressions with parameters of type Row

Modifier and Type	Method	Description
void	ExpressionEvaluatorVisitor.setRow(Row row)	Point this visitor at a new row — lets one visitor be reused across rows (see ExpressionEvaluator).

Method parameters in dev.frostlake.executor.expressions with type arguments of type Row

Modifier and Type	Method	Description
static PreparedInSet	PreparedInSet.build(List<Row> rows)

Constructors in dev.frostlake.executor.expressions with parameters of type Row

Modifier	Constructor	Description
	ExpressionEvaluatorVisitor(Table table, Row row, FunctionRegistry functionRegistry, Catalog catalog)

Uses of Row in dev.frostlake.executor.operators

Methods in dev.frostlake.executor.operators that return types with arguments of type Row

Modifier and Type	Method	Description
List<Row>	AsofJoinOperator.execute(List<Row> leftRows, OperatorContext context)
List<Row>	GroupByOperator.execute(List<Row> input, OperatorContext context)
List<Row>	HavingOperator.execute(List<Row> input, OperatorContext context)
List<Row>	JoinOperator.execute(List<Row> leftRows, OperatorContext context)
List<Row>	LimitOperator.execute(List<Row> input, OperatorContext context)
List<Row>	Operator.execute(List<Row> input, OperatorContext context)	Execute this operator on the input rows.
List<Row>	OperatorPipeline.execute(List<Row> input)	Execute the pipeline on the input rows.
List<Row>	ProjectOperator.execute(List<Row> input, OperatorContext context)
List<Row>	QualifyOperator.execute(List<Row> input, OperatorContext context)
List<Row>	TableFunctionOperator.execute(List<Row> input, OperatorContext context)
List<Row>	WhereOperator.execute(List<Row> input, OperatorContext context)

Methods in dev.frostlake.executor.operators with parameters of type Row

Modifier and Type	Method	Description
boolean	HavingEvaluator.evaluate(Expression condition, Row aggregatedRow)
boolean	QualifyEvaluator.evaluate(Expression condition, Row row, int rowIndex)
Object	RowExpressionEvaluator.evaluate(Expression expression, Row row)	Evaluate a parsed expression AST on a row.
boolean	JoinConditionEvaluator.matches(Row leftRow, Row rightRow)	Evaluate a join condition on a pair of rows.

Method parameters in dev.frostlake.executor.operators with type arguments of type Row

Modifier and Type	Method	Description
void	GroupByOperator.captureGroupRows(List<List<Row>> sink)	Capture each output row's source group rows into sink (parallel to the returned list), so a caller can apply HAVING aggregates that are not SELECT items over the original group.
static JoinOperator	JoinOperator.cross(Table leftTable, Table rightTable, List<Row> rightRows)	Create a CROSS JOIN operator (no condition).
Object	AggregateEvaluator.evaluate(int selectItemIndex, List<Row> rows)	Evaluate the select item at the given index on a group of rows.
List<Row>	AsofJoinOperator.execute(List<Row> leftRows, OperatorContext context)
List<Row>	GroupByOperator.execute(List<Row> input, OperatorContext context)
List<Row>	HavingOperator.execute(List<Row> input, OperatorContext context)
List<Row>	JoinOperator.execute(List<Row> leftRows, OperatorContext context)
List<Row>	LimitOperator.execute(List<Row> input, OperatorContext context)
List<Row>	Operator.execute(List<Row> input, OperatorContext context)	Execute this operator on the input rows.
List<Row>	OperatorPipeline.execute(List<Row> input)	Execute the pipeline on the input rows.
List<Row>	ProjectOperator.execute(List<Row> input, OperatorContext context)
List<Row>	QualifyOperator.execute(List<Row> input, OperatorContext context)
List<Row>	TableFunctionOperator.execute(List<Row> input, OperatorContext context)
List<Row>	WhereOperator.execute(List<Row> input, OperatorContext context)

Constructor parameters in dev.frostlake.executor.operators with type arguments of type Row

Modifier	Constructor	Description
	AsofJoinOperator(Table leftTable, Table rightTable, List<Row> rightRows, BinaryOperator matchOperator, Expression leftMatchExpression, RowExpressionEvaluator leftMatchEvaluator, Expression rightMatchExpression, RowExpressionEvaluator rightMatchEvaluator, JoinConditionEvaluator partitionEvaluator)
	JoinOperator(Table leftTable, Table rightTable, List<Row> rightRows, JoinType joinType, String joinCondition, JoinConditionEvaluator conditionEvaluator)	Create a JOIN operator with a condition evaluator.

Uses of Row in dev.frostlake.executor.procedural

Methods in dev.frostlake.executor.procedural that return Row

Modifier and Type	Method	Description
Row	Cursor.fetch()

Uses of Row in dev.frostlake.executor.streaming

Methods in dev.frostlake.executor.streaming that return Row

Modifier and Type	Method	Description
Row	RowMapper.map(Row row)
Row	FilterRowStream.next()
Row	LimitRowStream.next()
Row	ListRowStream.next()
Row	ProjectRowStream.next()
Row	RowStream.next()	The next row, or null when the stream is exhausted.

Methods in dev.frostlake.executor.streaming with parameters of type Row

Modifier and Type	Method	Description
Row	RowMapper.map(Row row)
boolean	RowPredicate.test(Row row)

Constructor parameters in dev.frostlake.executor.streaming with type arguments of type Row

Modifier	Constructor	Description
	ListRowStream(List<Row> rows)

Uses of Row in dev.frostlake.functions.window

Methods in dev.frostlake.functions.window with parameters of type Row

Modifier and Type	Method	Description
static double	WindowFunctionHelper.cumeDist(List<Row> sortedRows, Row currentRow, List<Object> orderValues)	CUME_DIST — fraction of rows with order value <= current; ranges (0, 1].
static int	WindowFunctionHelper.indexOf(List<Row> rows, Row target)
static long	WindowFunctionHelper.ntile(List<Row> sortedRows, Row currentRow, int buckets)	NTILE(n) — divides the sorted partition into n equal buckets, returns bucket number (1-based).
static double	WindowFunctionHelper.percentRank(List<Row> sortedRows, Row currentRow, List<Object> orderValues)	PERCENT_RANK — (rank - 1) / (N - 1); ranges [0, 1].

Method parameters in dev.frostlake.functions.window with type arguments of type Row

Modifier and Type	Method	Description
static double	WindowFunctionHelper.cumeDist(List<Row> sortedRows, Row currentRow, List<Object> orderValues)	CUME_DIST — fraction of rows with order value <= current; ranges (0, 1].
static int	WindowFunctionHelper.indexOf(List<Row> rows, Row target)
static long	WindowFunctionHelper.ntile(List<Row> sortedRows, Row currentRow, int buckets)	NTILE(n) — divides the sorted partition into n equal buckets, returns bucket number (1-based).
static double	WindowFunctionHelper.percentRank(List<Row> sortedRows, Row currentRow, List<Object> orderValues)	PERCENT_RANK — (rank - 1) / (N - 1); ranges [0, 1].

Uses of Row in dev.frostlake.metastore

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

Modifier and Type	Method	Description
List<Row>	DroppedObject.getRows()
Map<String,List<Row>>	DroppedObject.getTableRows()	Rows of every table in a dropped schema/database, keyed by fully-qualified name; null for a table.

Constructor parameters in dev.frostlake.metastore with type arguments of type Row

Modifier	Constructor	Description
	DroppedObject(Object object, List<Row> rows)
	DroppedObject(Object object, Map<String,List<Row>> tableRows)

Uses of Row in dev.frostlake.storage

Fields in dev.frostlake.storage with type parameters of type Row

Modifier and Type	Field	Description
final List<Row>	TableSnapshot.rows

Methods in dev.frostlake.storage that return Row

Modifier and Type	Method	Description
Row	Row.copy()
Row	TableStorage.getRow(int index)	The live row at index (used at deferred-apply time to capture pre-change values).
Row	TableStorage.getRowByPrimaryKey(Object key)
static Row	Row.of(List<Object> values)	Create a Row backed directly by the given list, WITHOUT a defensive copy.

Methods in dev.frostlake.storage that return types with arguments of type Row

Modifier and Type	Method	Description
List<Row>	ResultSet.getRows()
List<Row>	TableStorage.scan()

Methods in dev.frostlake.storage with parameters of type Row

Modifier and Type	Method	Description
void	ResultSet.addRow(Row row)
void	TableStorage.insert(Row written)
Object	TableStorage.primaryKeyOf(Row row)	The primary-key value (single value, or list for a composite key) of row; null if no PK.
void	TableStorage.replaceRow(int index, Row newRow)	Install a REPLACEMENT row at index — UPDATE never mutates a stored row in place, which is what lets TableStorage.takeSnapshot() keep pointer copies instead of deep copies.
void	TableStorage.update(int rowIndex, Row written)

Constructor parameters in dev.frostlake.storage with type arguments of type Row

Modifier	Constructor	Description
	TableSnapshot(long epochMillis, List<Row> rows)

Uses of Row in dev.frostlake.stream

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

Modifier and Type	Method	Description
void	StreamManager.trackDelete(String qualifiedTableName, Row row)	Track a DELETE operation
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(String qualifiedTableName, Row row)	Track an INSERT operation
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(String qualifiedTableName, Row oldRow, Row newRow)	Track an UPDATE operation
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).

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

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).

Uses of Row in dev.frostlake.transaction

Methods in dev.frostlake.transaction that return Row

Modifier and Type	Method	Description
Row	UpdateLog.getNewRow()
Row	UpdateLog.getOldRow()
Row	DeleteLog.getRow()
Row	InsertLog.getRow()
Row	TransactionWriteSet.pendingUpdate(String table, long rowId)	The pending new value for the base row with this stable id, or null if it isn't updated here.

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

Modifier and Type	Method	Description
List<Row>	TransactionWriteSet.overlayRows(String table, TableStorage base)	This transaction's view of table: committed base rows with this write set's updates applied and deletes removed, then this write set's inserts appended.
List<Row>	TransactionWriteSet.pendingInserts(String table)	A snapshot of the rows this transaction has inserted into table (empty if none); the indices line up with TransactionWriteSet.setPendingInsert(java.lang.String, int, dev.frostlake.storage.Row)/TransactionWriteSet.removePendingInsert(java.lang.String, int).

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

Modifier and Type	Method	Description
void	Transaction.logDelete(String tableName, int rowIndex, Row row)
void	Transaction.logInsert(String tableName, int rowIndex, Row row)
void	Transaction.logUpdate(String tableName, int rowIndex, Row oldRow, Row newRow)
void	TransactionWriteSet.recordInsert(String table, Row row)
void	TransactionWriteSet.recordUpdate(String table, long rowId, Row newValue)	Record a new value for an existing base row (by stable id).
void	TransactionWriteSet.setPendingInsert(String table, int index, Row newRow)	Replace a not-yet-committed inserted row (in-transaction UPDATE of a row this txn just inserted).

Constructors in dev.frostlake.transaction with parameters of type Row

Modifier	Constructor	Description
	DeleteLog(String tableName, int rowIndex, Row row)
	InsertLog(String tableName, int rowIndex, Row row)
	UpdateLog(String tableName, int rowIndex, Row oldRow, Row newRow)