Class LocalExecutionPlanner
java.lang.Object
org.elasticsearch.xpack.esql.planner.LocalExecutionPlanner
The local execution planner takes a plan (represented as PlanNode tree / digraph) as input and creates the corresponding
drivers that are used to execute the given plan.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classPlan representation that is geared towards execution on a single nodestatic final recordContext object used while generating a local plan.static classImmutable physical operation. -
Constructor Summary
ConstructorsConstructorDescriptionLocalExecutionPlanner(String sessionId, String clusterAlias, CancellableTask parentTask, BigArrays bigArrays, BlockFactory blockFactory, Settings settings, Configuration configuration, Supplier<ExchangeSource> exchangeSourceSupplier, Supplier<ExchangeSink> exchangeSinkSupplier, EnrichLookupService enrichLookupService, LookupFromIndexService lookupFromIndexService, InferenceService inferenceService, org.elasticsearch.xpack.esql.planner.PhysicalOperationProviders physicalOperationProviders, List<EsPhysicalOperationProviders.ShardContext> shardContexts) -
Method Summary
Modifier and TypeMethodDescriptionplan(String description, FoldContext foldCtx, PhysicalPlan localPhysicalPlan) turn the given plan into a list of drivers to execute
-
Constructor Details
-
LocalExecutionPlanner
public LocalExecutionPlanner(String sessionId, String clusterAlias, CancellableTask parentTask, BigArrays bigArrays, BlockFactory blockFactory, Settings settings, Configuration configuration, Supplier<ExchangeSource> exchangeSourceSupplier, Supplier<ExchangeSink> exchangeSinkSupplier, EnrichLookupService enrichLookupService, LookupFromIndexService lookupFromIndexService, InferenceService inferenceService, org.elasticsearch.xpack.esql.planner.PhysicalOperationProviders physicalOperationProviders, List<EsPhysicalOperationProviders.ShardContext> shardContexts)
-
-
Method Details
-
plan
public LocalExecutionPlanner.LocalExecutionPlan plan(String description, FoldContext foldCtx, PhysicalPlan localPhysicalPlan) turn the given plan into a list of drivers to execute
-