Class AbstractPhysicalOperationProviders
java.lang.Object
org.elasticsearch.xpack.esql.planner.AbstractPhysicalOperationProviders
- Direct Known Subclasses:
EsPhysicalOperationProviders
-
Method Summary
Modifier and TypeMethodDescriptionfieldExtractPhysicalOperation(FieldExtractExec fieldExtractExec, LocalExecutionPlanner.PhysicalOperation source) groupingPhysicalOperation(AggregateExec aggregateExec, LocalExecutionPlanner.PhysicalOperation source, LocalExecutionPlanner.LocalExecutionPlannerContext context) intermediateAttributes(List<? extends NamedExpression> aggregates, List<? extends Expression> groupings) Creates a standard layout for intermediate aggregations, typically used across exchanges.abstract Operator.OperatorFactoryordinalGroupingOperatorFactory(LocalExecutionPlanner.PhysicalOperation source, AggregateExec aggregateExec, List<GroupingAggregator.Factory> aggregatorFactories, Attribute attrSource, ElementType groupType, LocalExecutionPlanner.LocalExecutionPlannerContext context) Build a grouping operator that operates on ordinals if possible.sourcePhysicalOperation(EsQueryExec esQuery, LocalExecutionPlanner.LocalExecutionPlannerContext context)
-
Method Details
-
groupingPhysicalOperation
public final LocalExecutionPlanner.PhysicalOperation groupingPhysicalOperation(AggregateExec aggregateExec, LocalExecutionPlanner.PhysicalOperation source, LocalExecutionPlanner.LocalExecutionPlannerContext context) -
intermediateAttributes
public static List<Attribute> intermediateAttributes(List<? extends NamedExpression> aggregates, List<? extends Expression> groupings) Creates a standard layout for intermediate aggregations, typically used across exchanges. Puts the group first, followed by each aggregation.It's similar to the code above (groupingPhysicalOperation) but ignores the factory creation.
-
ordinalGroupingOperatorFactory
public abstract Operator.OperatorFactory ordinalGroupingOperatorFactory(LocalExecutionPlanner.PhysicalOperation source, AggregateExec aggregateExec, List<GroupingAggregator.Factory> aggregatorFactories, Attribute attrSource, ElementType groupType, LocalExecutionPlanner.LocalExecutionPlannerContext context) Build a grouping operator that operates on ordinals if possible. -
fieldExtractPhysicalOperation
LocalExecutionPlanner.PhysicalOperation fieldExtractPhysicalOperation(FieldExtractExec fieldExtractExec, LocalExecutionPlanner.PhysicalOperation source) -
sourcePhysicalOperation
LocalExecutionPlanner.PhysicalOperation sourcePhysicalOperation(EsQueryExec esQuery, LocalExecutionPlanner.LocalExecutionPlannerContext context)
-