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, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportEsqlQueryAction(TransportService transportService, ActionFilters actionFilters, PlanExecutor planExecutor, SearchService searchService, ExchangeService exchangeService, ClusterService clusterService, ProjectResolver projectResolver, ThreadPool threadPool, BigArrays bigArrays, BlockFactoryProvider blockFactoryProvider, Client client, NamedWriteableRegistry registry, IndexNameExpressionResolver indexNameExpressionResolver, UsageService usageService) -
Method Summary
Modifier and TypeMethodDescriptioncreateTask(EsqlQueryRequest request, long id, String type, String action, TaskId parentTaskId, Map<String, String> headers, Map<String, String> originHeaders, AsyncExecutionId asyncExecutionId) protected voiddoExecute(Task task, EsqlQueryRequest request, ActionListener<EsqlQueryResponse> listener) voidexecute(EsqlQueryRequest request, EsqlQueryTask task, ActionListener<EsqlQueryResponse> listener) initialResponse(EsqlQueryTask task) readResponse(StreamInput inputStream) Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Constructor Details
-
TransportEsqlQueryAction
@Inject public TransportEsqlQueryAction(TransportService transportService, ActionFilters actionFilters, PlanExecutor planExecutor, SearchService searchService, ExchangeService exchangeService, ClusterService clusterService, ProjectResolver projectResolver, ThreadPool threadPool, BigArrays bigArrays, BlockFactoryProvider blockFactoryProvider, Client client, NamedWriteableRegistry registry, IndexNameExpressionResolver indexNameExpressionResolver, UsageService usageService)
-
-
Method Details
-
doExecute
protected void doExecute(Task task, EsqlQueryRequest request, ActionListener<EsqlQueryResponse> listener) - Specified by:
doExecutein classTransportAction<EsqlQueryRequest,EsqlQueryResponse>
-
execute
public void execute(EsqlQueryRequest request, EsqlQueryTask task, ActionListener<EsqlQueryResponse> listener) - Specified by:
executein interfaceAsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse, EsqlQueryTask>
-
exchangeService
-
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:
createTaskin interfaceAsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse, EsqlQueryTask>
-
initialResponse
- Specified by:
initialResponsein interfaceAsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse, EsqlQueryTask>
-
readResponse
- Specified by:
readResponsein interfaceAsyncTaskManagementService.AsyncOperation<EsqlQueryRequest,EsqlQueryResponse, EsqlQueryTask> - Throws:
IOException
-
getLookupFromIndexService
-