Module physical 

Volcano PhysicalOperator trait shared by every operator in this crate.

Structs

OperatorBatchCursor

Borrowing iterator over a physical operator. Construction opens the pipeline; exhaustion and execution errors close it exactly once. Dropping an unfinished cursor performs best-effort cleanup.

PhysicalOrder

A leading physical row-order property carried between operators.

Enums

ExecError

Operator-pipeline error type. Wraps SQL evaluation errors so call sites do not need to juggle two error enums.

Traits

PhysicalOperator

Volcano-style streaming operator. Operators form a tree; each operator pulls from its children inside next and emits a Batch until the input is exhausted.

Functions

order_expression_position

Resolve a simple ordering expression to one logical position without collapsing duplicate or qualified SQL identities into a display label.

ordering_satisfies

Return whether actual has required as an ordering prefix.

run_to_batches

Convenience: collect every batch from op until exhaustion. The operator is opened and closed for the caller. Useful for tests and for callers that do not need streaming behaviour.

run_to_rows

Run the operator and concatenate all output batches into a single flat row vector. The schema of the first batch is the result schema.

Type Aliases

ExecResult