Expand description
Physical operators that actually execute queries.
These are the building blocks of query execution. The optimizer picks which operators to use and how to wire them together.
Graph operators:
ScanOperator- Read nodes/edges from storageExpandOperator- Traverse edges (the core of graph queries)VariableLengthExpandOperator- Paths of variable lengthShortestPathOperator- Find shortest paths
Relational operators:
FilterOperator- Apply predicatesProjectOperator- Select/transform columnsHashJoinOperator- Efficient equi-joinsHashAggregateOperator- Group by with aggregationSortOperator- Order resultsLimitOperator- SKIP and LIMIT
The push submodule has push-based variants for pipeline execution.
Re-exports§
pub use push::AggregatePushOperator;pub use push::DistinctMaterializingOperator;pub use push::DistinctPushOperator;pub use push::FilterPushOperator;pub use push::LimitPushOperator;pub use push::ProjectPushOperator;pub use push::SkipLimitPushOperator;pub use push::SkipPushOperator;pub use push::SortPushOperator;pub use push::SpillableAggregatePushOperator;pub use push::SpillableSortPushOperator;
Modules§
- push
- Push-based operator implementations.
- single_
row - Single row operator for producing a single empty row.
Structs§
- AddLabel
Operator - Operator that adds labels to nodes.
- Aggregate
Expr - An aggregation expression.
- Create
Edge Operator - Operator that creates new edges.
- Create
Node Operator - Operator that creates new nodes.
- Delete
Edge Operator - Operator that deletes edges.
- Delete
Node Operator - Operator that deletes nodes.
- Distinct
Operator - Distinct operator.
- Equality
Condition - A simple equality condition for nested loop joins.
- Expand
Operator - An expand operator that traverses edges from source nodes.
- Expression
Predicate - An expression-based predicate that evaluates logical expressions.
- Filter
Operator - A filter operator that applies a predicate to filter rows.
- Hash
Aggregate Operator - Hash-based aggregate operator.
- Hash
Join Operator - Hash join operator.
- Limit
Operator - Limit operator.
- Limit
Skip Operator - Combined Limit and Skip operator.
- Merge
Operator - Merge operator for MERGE clause.
- Nested
Loop Join Operator - Nested loop join operator.
- Project
Operator - A project operator that selects and transforms columns.
- Remove
Label Operator - Operator that removes labels from nodes.
- Scan
Operator - A scan operator that reads nodes from storage.
- SetProperty
Operator - Operator that sets properties on nodes or edges.
- Shortest
Path Operator - Operator that finds shortest paths between source and target nodes.
- Simple
Aggregate Operator - Simple (non-grouping) aggregate operator for global aggregations.
- Skip
Operator - Skip operator.
- SortKey
- A sort key specification.
- Sort
Operator - Sort operator.
- Union
Operator - Union operator that combines results from multiple inputs.
- Unwind
Operator - Unwind operator that expands a list column into individual rows.
- Variable
Length Expand Operator - An expand operator that handles variable-length path patterns like
*1..3.
Enums§
- Aggregate
Function - Aggregation function types.
- Binary
Filter Op - Binary operators for filter expressions.
- Filter
Expression - A filter expression that can be evaluated.
- HashKey
- A hash key that can be hashed and compared for join operations.
- Join
Type - The type of join to perform.
- Null
Order - Null ordering.
- Operator
Error - Error during operator execution.
- Project
Expr - A projection expression.
- Property
Source - Source for a property value.
- Sort
Direction - Sort direction.
- Unary
Filter Op - Unary operators for filter expressions.
Traits§
- Join
Condition - Trait for join conditions.
- Operator
- The core trait for pull-based operators.
- Predicate
- A predicate for filtering rows.
Type Aliases§
- Operator
Result - Result of executing an operator.