Package org.elasticsearch.xpack.esql.execution

Class PlanExecutor

java.lang.Object

org.elasticsearch.xpack.esql.execution.PlanExecutor

public class PlanExecutor
extends Object

Constructor Summary

Constructors

Constructor

Description

PlanExecutor(IndexResolver indexResolver, MeterRegistry meterRegistry, XPackLicenseState licenseState, EsqlQueryLog queryLog, List<BiConsumer<LogicalPlan,Failures>> extraCheckers, CrossProjectModeDecider crossProjectModeDecider, DataSourceModule dataSourceModule, EsqlFunctionRegistry functionRegistry, PromqlFunctionRegistry promqlFunctionRegistry, EsqlParser parser, ExternalSourceCacheService cacheService, AnalysisRegistry analysisRegistry)

Method Summary

Modifier and Type	Method	Description
ExternalSourceCacheService	cacheService()
DataSourceModule	dataSourceModule()
void	esql(EsqlQueryRequest request, String sessionId, TransportVersion localClusterMinimumVersion, AnalyzerSettings analyzerSettings, EnrichPolicyResolver enrichPolicyResolver, ViewResolver viewResolver, DatasetResolver datasetResolver, EsqlExecutionInfo executionInfo, IndicesExpressionGrouper indicesExpressionGrouper, EsqlSession.PlanRunner planRunner, TransportActionServices services, Executor externalSourceExecutor, int externalSourceConcurrency, BooleanSupplier cancellation, ActionListener<Versioned<Result>> listener)
IndexResolver	indexResolver()
Metrics	metrics()

Methods inherited from class java.lang.Object

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

Constructor Details

PlanExecutor

public PlanExecutor(IndexResolver indexResolver,
 MeterRegistry meterRegistry,
 XPackLicenseState licenseState,
 EsqlQueryLog queryLog,
 List<BiConsumer<LogicalPlan,Failures>> extraCheckers,
 CrossProjectModeDecider crossProjectModeDecider,
 DataSourceModule dataSourceModule,
 EsqlFunctionRegistry functionRegistry,
 PromqlFunctionRegistry promqlFunctionRegistry,
 EsqlParser parser,
 ExternalSourceCacheService cacheService,
 AnalysisRegistry analysisRegistry)

Method Details

esql

public void esql(EsqlQueryRequest request,
 String sessionId,
 TransportVersion localClusterMinimumVersion,
 AnalyzerSettings analyzerSettings,
 EnrichPolicyResolver enrichPolicyResolver,
 ViewResolver viewResolver,
 DatasetResolver datasetResolver,
 EsqlExecutionInfo executionInfo,
 IndicesExpressionGrouper indicesExpressionGrouper,
 EsqlSession.PlanRunner planRunner,
 TransportActionServices services,
 Executor externalSourceExecutor,
 int externalSourceConcurrency,
 BooleanSupplier cancellation,
 ActionListener<Versioned<Result>> listener)

Parameters:

externalSourceExecutor - Executor for ExternalSourceResolver work — glob expansion, footer reads, schema reconciliation. Must not be the SEARCH pool: a wildcard external query would otherwise starve regular ES searches and other ES|QL queries. Production wiring passes esql_worker.

externalSourceConcurrency - maximum number of in-flight per-file metadata reads during a multi-file resolve. Production wiring passes ExternalSourceSettings.blobStoreConcurrency(Settings) (the snapshot_meta shape, capped at 100): footer reads are async (the pool thread is released across the network round-trip), so the bound caps concurrent in-flight reads rather than pinning that many threads.

cancellation - consulted before each per-file footer read so a wide-glob discovery aborts promptly when the originating query is cancelled.

indexResolver

public IndexResolver indexResolver()

metrics

public Metrics metrics()

dataSourceModule

public DataSourceModule dataSourceModule()

cacheService

public ExternalSourceCacheService cacheService()