Package org.elasticsearch.xpack.esql.enrich

Class LookupExecutionPlanner

java.lang.Object

org.elasticsearch.xpack.esql.enrich.LookupExecutionPlanner

public class LookupExecutionPlanner
extends Object

Plans the execution of a lookup physical plan Converts PhysicalPlan nodes into PhysicalOperation with operator factories Also converts PhysicalOperation into actual Operators

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LookupExecutionPlanner.QueryListFromPlanFactory	Functional interface for creating a LookupEnrichQueryGenerator from plan data.

Constructor Summary

Constructors

Constructor	Description
LookupExecutionPlanner(BlockFactory blockFactory, BigArrays bigArrays, LocalCircuitBreaker.SizeSettings localBreakerSettings)

Method Summary

Modifier and Type	Method	Description
LocalExecutionPlanner.PhysicalOperation	buildOperatorFactories(PlannerSettings plannerSettings, PhysicalPlan physicalPlan, BlockOptimization blockOptimization, SourceOperator.SourceOperatorFactory sourceFactory, FoldContext foldCtx, LookupExecutionPlanner.QueryListFromPlanFactory queryListFromPlanFactory, Source lookupSource)	Creates a PhysicalOperation with operator factories, matching LocalExecutionPlanner's pattern.
org.elasticsearch.xpack.esql.enrich.LookupFromIndexService.LookupQueryPlan	buildOperators(LocalExecutionPlanner.PhysicalOperation physicalOperation, AbstractLookupService.LookupShardContext shardContext, List<org.elasticsearch.core.Releasable> releasables, Page inputPage, AliasFilter aliasFilter)	Creates the actual operators from the PhysicalOperation using DriverContext.

Methods inherited from class java.lang.Object

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

Constructor Details

LookupExecutionPlanner

public LookupExecutionPlanner(BlockFactory blockFactory,
 BigArrays bigArrays,
 LocalCircuitBreaker.SizeSettings localBreakerSettings)

Method Details

buildOperatorFactories

public LocalExecutionPlanner.PhysicalOperation buildOperatorFactories(PlannerSettings plannerSettings,
 PhysicalPlan physicalPlan,
 BlockOptimization blockOptimization,
 SourceOperator.SourceOperatorFactory sourceFactory,
 FoldContext foldCtx,
 LookupExecutionPlanner.QueryListFromPlanFactory queryListFromPlanFactory,
 Source lookupSource)

Creates a PhysicalOperation with operator factories, matching LocalExecutionPlanner's pattern.

Parameters:

lookupSource - the Source to use for warning messages (from the original LOOKUP JOIN expression), passed separately because plan nodes conventionally discard Source during serialization.

buildOperators

public org.elasticsearch.xpack.esql.enrich.LookupFromIndexService.LookupQueryPlan buildOperators(LocalExecutionPlanner.PhysicalOperation physicalOperation,
 AbstractLookupService.LookupShardContext shardContext,
 List<org.elasticsearch.core.Releasable> releasables,
 Page inputPage,
 AliasFilter aliasFilter)

Creates the actual operators from the PhysicalOperation using DriverContext. The collectedPages list is created here and stored in LookupDriverContext.