Expand description
Physical operator implementations.
Re-exports§
pub use aggregate::AggregateOp;pub use bfs::ShortestPathOp;pub use cross_product::CrossProductOp;pub use distinct::DistinctOp;pub use empty::EmptyOp;pub use filter::FilterOp;pub use hash_join::HashJoinOp;pub use limit::LimitOp;pub use projection::ProjectionOp;pub use recursive_join::RecursiveJoinOp;pub use scan::ScanNodeOp;pub use sort::OrderByOp;pub use unwind::UnwindOp;
Modules§
- aggregate
- Aggregate operator — hash-based GROUP BY + aggregation.
- bfs
- BFS shortest path — find shortest path between two nodes.
- cross_
product - Cross product operator — Cartesian product of left × right.
- distinct
- Distinct operator — hash-based deduplication.
- empty
- Empty operator — produces a single row with no columns, then exhausts.
- filter
- Filter operator — evaluates predicate per row, keeps passing rows.
- hash_
join - Hash join operator — build hash table from left side, probe from right.
- limit
- Limit operator — SKIP + LIMIT row counting.
- projection
- Projection operator — evaluates expression list per row.
- recursive_
join - Recursive join operator — variable-length path traversal via BFS.
- scan
- Scan operator — reads rows from Storage trait.
- sort
- OrderBy operator — materializes all rows, sorts, then emits.
- unwind
- Unwind operator — flattens a list expression into individual rows.