Package org.elasticsearch.xpack.esql.plugin

Class TransportEsqlQueryAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<EsqlQueryRequest,EsqlQueryResponse>

org.elasticsearch.action.support.HandledTransportAction<EsqlQueryRequest,EsqlQueryResponse>

org.elasticsearch.xpack.esql.plugin.TransportEsqlQueryAction

All Implemented Interfaces:

AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

public class TransportEsqlQueryAction
extends HandledTransportAction<EsqlQueryRequest,EsqlQueryResponse>
implements AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

Field Summary

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, taskManager

Constructor Summary

Constructors

Constructor

Description

TransportEsqlQueryAction(TransportService transportService, ActionFilters actionFilters, PlanExecutor planExecutor, SearchService searchService, ExchangeService exchangeService, ClusterService clusterService, ViewResolver viewResolver, ProjectResolver projectResolver, ThreadPool threadPool, BigArrays bigArrays, BlockFactoryProvider blockFactoryProvider, Client client, NamedWriteableRegistry registry, IndexNameExpressionResolver indexNameExpressionResolver, UsageService usageService, UserAgentParserRegistry userAgentParserRegistry, ActionLoggingFieldsProvider fieldProvider, ActivityLogWriterProvider logWriterProvider, CrossProjectModeDecider crossProjectModeDecider)

Method Summary

Modifier and Type	Method	Description
EsqlQueryTask	createTask(EsqlQueryRequest request, long id, String type, String action, TaskId parentTaskId, Map<String,String> headers, Map<String,String> originHeaders, AsyncExecutionId asyncExecutionId)
protected void	doExecute(Task task, EsqlQueryRequest request, ActionListener<EsqlQueryResponse> listener)
EnrichLookupService	enrichLookupService()
ExchangeService	exchangeService()
void	execute(EsqlQueryRequest request, EsqlQueryTask task, ActionListener<EsqlQueryResponse> listener)
protected Executor	externalSourceExecutor()	Returns the executor used for external source I/O (e.g.
LookupFromIndexService	getLookupFromIndexService()
EsqlQueryResponse	initialResponse(EsqlQueryTask task)
void	onFailureAfterTimeout(Exception exception)
void	onResponseAfterTimeout(EsqlQueryResponse response)
EsqlQueryResponse	readResponse(StreamInput inputStream)

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, executeDirect, localOnly

Methods inherited from class java.lang.Object

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

Constructor Details

TransportEsqlQueryAction

@Inject
public TransportEsqlQueryAction(TransportService transportService,
 ActionFilters actionFilters,
 PlanExecutor planExecutor,
 SearchService searchService,
 ExchangeService exchangeService,
 ClusterService clusterService,
 ViewResolver viewResolver,
 ProjectResolver projectResolver,
 ThreadPool threadPool,
 BigArrays bigArrays,
 BlockFactoryProvider blockFactoryProvider,
 Client client,
 NamedWriteableRegistry registry,
 IndexNameExpressionResolver indexNameExpressionResolver,
 UsageService usageService,
 UserAgentParserRegistry userAgentParserRegistry,
 ActionLoggingFieldsProvider fieldProvider,
 ActivityLogWriterProvider logWriterProvider,
 CrossProjectModeDecider crossProjectModeDecider)

Method Details

externalSourceExecutor

protected Executor externalSourceExecutor()

Returns the executor used for external source I/O (e.g. EXTERNAL/FROM external_source operators). Isolated from ThreadPool.Names.SEARCH to prevent heavy external queries from starving regular ES operations. Currently shares esql_worker with compute drivers; override this method when a dedicated I/O pool is introduced.

doExecute

protected void doExecute(Task task,
 EsqlQueryRequest request,
 ActionListener<EsqlQueryResponse> listener)

Specified by:

doExecute in class TransportAction<EsqlQueryRequest,EsqlQueryResponse>

execute

public void execute(EsqlQueryRequest request,
 EsqlQueryTask task,
 ActionListener<EsqlQueryResponse> listener)

Specified by:

execute in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

onResponseAfterTimeout

public void onResponseAfterTimeout(EsqlQueryResponse response)

Specified by:

onResponseAfterTimeout in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

onFailureAfterTimeout

public void onFailureAfterTimeout(Exception exception)

Specified by:

onFailureAfterTimeout in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

exchangeService

public ExchangeService exchangeService()

enrichLookupService

public EnrichLookupService enrichLookupService()

createTask

public EsqlQueryTask createTask(EsqlQueryRequest request,
 long id,
 String type,
 String action,
 TaskId parentTaskId,
 Map<String,String> headers,
 Map<String,String> originHeaders,
 AsyncExecutionId asyncExecutionId)

Specified by:

createTask in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

initialResponse

public EsqlQueryResponse initialResponse(EsqlQueryTask task)

Specified by:

initialResponse in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

readResponse

public EsqlQueryResponse readResponse(StreamInput inputStream)
                               throws IOException

Specified by:

readResponse in interface AsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse,EsqlQueryTask>

Throws:

IOException

getLookupFromIndexService

public LookupFromIndexService getLookupFromIndexService()