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.sourcePhysicalOperation(EsQueryExec esQuery, LocalExecutionPlanner.LocalExecutionPlannerContext context) abstract Operator.OperatorFactorytimeSeriesAggregatorOperatorFactory(TimeSeriesAggregateExec ts, AggregatorMode aggregatorMode, List<GroupingAggregator.Factory> aggregatorFactories, List<BlockHash.GroupSpec> groupSpecs, LocalExecutionPlanner.LocalExecutionPlannerContext context) timeSeriesSourceOperation(TimeSeriesSourceExec ts, 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.
-
timeSeriesAggregatorOperatorFactory
public abstract Operator.OperatorFactory timeSeriesAggregatorOperatorFactory(TimeSeriesAggregateExec ts, AggregatorMode aggregatorMode, List<GroupingAggregator.Factory> aggregatorFactories, List<BlockHash.GroupSpec> groupSpecs, LocalExecutionPlanner.LocalExecutionPlannerContext context) -
fieldExtractPhysicalOperation
LocalExecutionPlanner.PhysicalOperation fieldExtractPhysicalOperation(FieldExtractExec fieldExtractExec, LocalExecutionPlanner.PhysicalOperation source) -
sourcePhysicalOperation
LocalExecutionPlanner.PhysicalOperation sourcePhysicalOperation(EsQueryExec esQuery, LocalExecutionPlanner.LocalExecutionPlannerContext context) -
timeSeriesSourceOperation
LocalExecutionPlanner.PhysicalOperation timeSeriesSourceOperation(TimeSeriesSourceExec ts, LocalExecutionPlanner.LocalExecutionPlannerContext context)
-