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, EsqlParser parser, ExternalSourceCacheService cacheService)

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, EsqlExecutionInfo executionInfo, IndicesExpressionGrouper indicesExpressionGrouper, EsqlSession.PlanRunner planRunner, TransportActionServices services, 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,
 EsqlParser parser,
 ExternalSourceCacheService cacheService)

Method Details

esql

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

indexResolver

public IndexResolver indexResolver()

metrics

public Metrics metrics()

dataSourceModule

public DataSourceModule dataSourceModule()

cacheService

public ExternalSourceCacheService cacheService()