Skip to main content

Module operators

Module operators 

Source
Expand description

Physical operators for query execution.

This module provides the physical operators that form the execution tree:

  • Scan: Read nodes/edges from storage
  • Expand: Traverse edges from nodes
  • Filter: Apply predicates to filter rows
  • Project: Select and transform columns
  • Join: Hash join and nested loop join
  • Aggregate: Group by and aggregation functions
  • Sort: Order results by columns
  • Limit: Limit the number of results

The push submodule contains push-based operator implementations.

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.

Structs§

AddLabelOperator
Operator that adds labels to nodes.
AggregateExpr
An aggregation expression.
CreateEdgeOperator
Operator that creates new edges.
CreateNodeOperator
Operator that creates new nodes.
DeleteEdgeOperator
Operator that deletes edges.
DeleteNodeOperator
Operator that deletes nodes.
DistinctOperator
Distinct operator.
EqualityCondition
A simple equality condition for nested loop joins.
ExpandOperator
An expand operator that traverses edges from source nodes.
ExpressionPredicate
An expression-based predicate that evaluates logical expressions.
FilterOperator
A filter operator that applies a predicate to filter rows.
HashAggregateOperator
Hash-based aggregate operator.
HashJoinOperator
Hash join operator.
LimitOperator
Limit operator.
LimitSkipOperator
Combined Limit and Skip operator.
MergeOperator
Merge operator for MERGE clause.
NestedLoopJoinOperator
Nested loop join operator.
ProjectOperator
A project operator that selects and transforms columns.
RemoveLabelOperator
Operator that removes labels from nodes.
ScanOperator
A scan operator that reads nodes from storage.
SetPropertyOperator
Operator that sets properties on nodes or edges.
SimpleAggregateOperator
Simple (non-grouping) aggregate operator for global aggregations.
SkipOperator
Skip operator.
SortKey
A sort key specification.
SortOperator
Sort operator.
UnionOperator
Union operator that combines results from multiple inputs.
UnwindOperator
Unwind operator that expands a list column into individual rows.

Enums§

AggregateFunction
Aggregation function types.
BinaryFilterOp
Binary operators for filter expressions.
FilterExpression
A filter expression that can be evaluated.
HashKey
A hash key that can be hashed and compared for join operations.
JoinType
The type of join to perform.
NullOrder
Null ordering.
OperatorError
Error during operator execution.
ProjectExpr
A projection expression.
PropertySource
Source for a property value.
SortDirection
Sort direction.
UnaryFilterOp
Unary operators for filter expressions.

Traits§

JoinCondition
Trait for join conditions.
Operator
Trait for physical operators.
Predicate
A predicate for filtering rows.

Type Aliases§

OperatorResult
Result of executing an operator.