Re-exports§
pub use columnar_scan::ColumnarScanIterator;pub use columnar_scan::create_columnar_scan_iterator;pub use iterator::FilterIterator;pub use iterator::LimitIterator;pub use iterator::RowIterator;pub use iterator::ScanIterator;pub use iterator::SortIterator;
Modules§
- aggregate
- columnar_
scan - iterator
- Iterator-based query execution pipeline.
- join
- subquery
Functions§
- build_
streaming_ pipeline - Build a streaming iterator pipeline from a logical plan (FR-7).
- build_
streaming_ pipeline_ with_ policy - create_
fenced_ range_ scan_ iterator - Creates the only scan iterator intended for a fenced remote range worker.
- create_
scan_ iterator - Create a streaming scan iterator for FR-7 compliance.
- execute_
fenced_ range_ scan - Executes a materialized fenced range scan for a remote worker.
- execute_
query - Execute a SELECT logical plan and return a query result.
- execute_
query_ streaming - Execute a SELECT logical plan and return a streaming query result.
- execute_
query_ streaming_ with_ policy - execute_
query_ with_ policy - project_
row_ values - Apply one projection with the same expression kernel as local query execution. The distributed worker/assembler boundary uses this helper for its already fenced, already authorized rows; it does not deserialize a logical plan.
- projected_
columns - Build the public output schema for a projection without executing rows.