Package org.elasticsearch.xpack.esql.planner

Class LocalExecutionPlanner

java.lang.Object

org.elasticsearch.xpack.esql.planner.LocalExecutionPlanner

public class LocalExecutionPlanner
extends Object

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 Classes

Modifier and Type	Class	Description
static class	LocalExecutionPlanner.LocalExecutionPlan	Plan representation that is geared towards execution on a single node
static final record	LocalExecutionPlanner.LocalExecutionPlannerContext	Context object used while generating a local plan.
static class	LocalExecutionPlanner.PhysicalOperation	Immutable physical operation.

Constructor Summary

Constructors

Constructor

Description

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, UserAgentParserRegistry userAgentParserRegistry, org.elasticsearch.xpack.esql.planner.PhysicalOperationProviders physicalOperationProviders, OperatorFactoryRegistry operatorFactoryRegistry)

Method Summary

Modifier and Type	Method	Description
LocalExecutionPlanner.LocalExecutionPlan	plan(String description, FoldContext foldCtx, PlannerSettings plannerSettings, PhysicalPlan localPhysicalPlan, IndexedByShardId<? extends EsPhysicalOperationProviders.ShardContext> shardContexts)	turn the given plan into a list of drivers to execute
static LocalExecutionPlanner.PhysicalOperation	planProject(ProjectExec project, LocalExecutionPlanner.PhysicalOperation source)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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,
 UserAgentParserRegistry userAgentParserRegistry,
 org.elasticsearch.xpack.esql.planner.PhysicalOperationProviders physicalOperationProviders,
 OperatorFactoryRegistry operatorFactoryRegistry)

Method Details

plan

public LocalExecutionPlanner.LocalExecutionPlan plan(String description,
 FoldContext foldCtx,
 PlannerSettings plannerSettings,
 PhysicalPlan localPhysicalPlan,
 IndexedByShardId<? extends EsPhysicalOperationProviders.ShardContext> shardContexts)

turn the given plan into a list of drivers to execute

planProject

public static LocalExecutionPlanner.PhysicalOperation planProject(ProjectExec project,
 LocalExecutionPlanner.PhysicalOperation source)