Class EsqlSession
java.lang.Object
org.elasticsearch.xpack.esql.session.EsqlSession
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interfaceInterface for running the underlying plan. -
Constructor Summary
ConstructorsConstructorDescriptionEsqlSession(String sessionId, Configuration configuration, IndexResolver indexResolver, EnrichPolicyResolver enrichPolicyResolver, PreAnalyzer preAnalyzer, EsqlFunctionRegistry functionRegistry, LogicalPlanOptimizer logicalPlanOptimizer, Mapper mapper, Verifier verifier, PlanTelemetry planTelemetry, IndicesExpressionGrouper indicesExpressionGrouper, TransportActionServices services) -
Method Summary
Modifier and TypeMethodDescriptionvoidanalyzedPlan(LogicalPlan parsed, EsqlExecutionInfo executionInfo, QueryBuilder requestFilter, ActionListener<LogicalPlan> logicalPlanListener) voidexecute(EsqlQueryRequest request, EsqlExecutionInfo executionInfo, EsqlSession.PlanRunner planRunner, ActionListener<Result> listener) Execute an ESQL request.voidexecuteOptimizedPlan(EsqlQueryRequest request, EsqlExecutionInfo executionInfo, EsqlSession.PlanRunner planRunner, LogicalPlan optimizedPlan, ActionListener<Result> listener) Execute an analyzed plan.optimizedPhysicalPlan(LogicalPlan optimizedPlan) optimizedPlan(LogicalPlan logicalPlan) physicalPlan(LogicalPlan optimizedPlan)
-
Constructor Details
-
EsqlSession
public EsqlSession(String sessionId, Configuration configuration, IndexResolver indexResolver, EnrichPolicyResolver enrichPolicyResolver, PreAnalyzer preAnalyzer, EsqlFunctionRegistry functionRegistry, LogicalPlanOptimizer logicalPlanOptimizer, Mapper mapper, Verifier verifier, PlanTelemetry planTelemetry, IndicesExpressionGrouper indicesExpressionGrouper, TransportActionServices services)
-
-
Method Details
-
sessionId
-
execute
public void execute(EsqlQueryRequest request, EsqlExecutionInfo executionInfo, EsqlSession.PlanRunner planRunner, ActionListener<Result> listener) Execute an ESQL request. -
executeOptimizedPlan
public void executeOptimizedPlan(EsqlQueryRequest request, EsqlExecutionInfo executionInfo, EsqlSession.PlanRunner planRunner, LogicalPlan optimizedPlan, ActionListener<Result> listener) Execute an analyzed plan. Most code should prefer callingexecute(org.elasticsearch.xpack.esql.action.EsqlQueryRequest, org.elasticsearch.xpack.esql.action.EsqlExecutionInfo, org.elasticsearch.xpack.esql.session.EsqlSession.PlanRunner, org.elasticsearch.action.ActionListener<org.elasticsearch.xpack.esql.session.Result>)but this is public for testing. -
analyzedPlan
public void analyzedPlan(LogicalPlan parsed, EsqlExecutionInfo executionInfo, QueryBuilder requestFilter, ActionListener<LogicalPlan> logicalPlanListener) -
optimizedPlan
-
physicalPlan
-
optimizedPhysicalPlan
-