Expand description
Push-based operator implementations.
These operators implement the PushOperator trait for push-based execution,
where data flows forward through the pipeline via push() calls.
§Non-blocking operators
FilterPushOperator- Filters rows based on predicatesProjectPushOperator- Evaluates expressions to produce columnsLimitPushOperator- Limits output rows (enables early termination)
§Pipeline breakers
SortPushOperator- Buffers all input, produces sorted outputAggregatePushOperator- Groups and aggregates, produces in finalizeDistinctPushOperator- Filters duplicates (incremental)DistinctMaterializingOperator- Filters duplicates (materializing)
Structs§
- Aggregate
Expr - Aggregate expression.
- Aggregate
Push Operator - Push-based aggregate operator.
- AndPredicate
- Logical AND of two predicates.
- Binary
Expr - Binary arithmetic expression.
- Column
Expr - Expression that returns a column value.
- Column
Predicate - Column comparison predicate.
- Constant
Expr - Expression that returns a constant value.
- Distinct
Materializing Operator - Push-based distinct operator that materializes all input first.
- Distinct
Push Operator - Push-based distinct operator.
- Filter
Push Operator - Push-based filter operator.
- Limit
Push Operator - Push-based limit operator.
- NotNull
Predicate - Not null predicate.
- OrPredicate
- Logical OR of two predicates.
- Project
Push Operator - Push-based project operator.
- Skip
Limit Push Operator - Combined skip and limit operator.
- Skip
Push Operator - Push-based skip operator.
- SortKey
- Sort key specification.
- Sort
Push Operator - Push-based sort operator.
- Spillable
Aggregate Push Operator - Push-based aggregate operator with spilling support.
- Spillable
Sort Push Operator - Push-based sort operator with spilling support.
Enums§
- Aggregate
Function - Aggregation function type.
- ArithOp
- Arithmetic operations.
- Compare
Op - Comparison operator.
- Null
Order - Null handling in sort.
- Sort
Direction - Sort direction.
Constants§
- DEFAULT_
AGGREGATE_ SPILL_ THRESHOLD - Default spill threshold for aggregates (number of groups).
- DEFAULT_
SPILL_ THRESHOLD - Default spill threshold (number of rows before spilling).
Traits§
- Filter
Predicate - Predicate for filtering rows.
- Project
Expression - Expression that can be evaluated to produce a value.