Class TransportEsqlStatsAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<EsqlStatsRequest,EsqlStatsResponse>
org.elasticsearch.action.support.nodes.TransportNodesAction<EsqlStatsRequest,EsqlStatsResponse,org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest,EsqlStatsResponse.NodeStatsResponse,Void>
org.elasticsearch.xpack.esql.plugin.TransportEsqlStatsAction
public class TransportEsqlStatsAction
extends TransportNodesAction<EsqlStatsRequest,EsqlStatsResponse,org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest,EsqlStatsResponse.NodeStatsResponse,Void>
Performs the stats operation.
-
Field Summary
Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
clusterService, transportNodeAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportEsqlStatsAction(TransportService transportService, ClusterService clusterService, FeatureService featureService, ThreadPool threadPool, ActionFilters actionFilters, PlanExecutor planExecutor) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequestnewNodeRequest(EsqlStatsRequest request) protected EsqlStatsResponse.NodeStatsResponsenewNodeResponse(StreamInput in, DiscoveryNode node) protected EsqlStatsResponsenewResponse(EsqlStatsRequest request, List<EsqlStatsResponse.NodeStatsResponse> nodes, List<FailedNodeException> failures) protected EsqlStatsResponse.NodeStatsResponsenodeOperation(org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest request, Task task) protected DiscoveryNode[]resolveRequest(EsqlStatsRequest request, ClusterState clusterState) Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesAction
createActionContext, doExecute, newResponseAsync, nodeOperationAsyncMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Constructor Details
-
TransportEsqlStatsAction
@Inject public TransportEsqlStatsAction(TransportService transportService, ClusterService clusterService, FeatureService featureService, ThreadPool threadPool, ActionFilters actionFilters, PlanExecutor planExecutor)
-
-
Method Details
-
resolveRequest
- Overrides:
resolveRequestin classTransportNodesAction<EsqlStatsRequest,EsqlStatsResponse, org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest, EsqlStatsResponse.NodeStatsResponse, Void>
-
newResponse
protected EsqlStatsResponse newResponse(EsqlStatsRequest request, List<EsqlStatsResponse.NodeStatsResponse> nodes, List<FailedNodeException> failures) - Specified by:
newResponsein classTransportNodesAction<EsqlStatsRequest,EsqlStatsResponse, org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest, EsqlStatsResponse.NodeStatsResponse, Void>
-
newNodeRequest
protected org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest newNodeRequest(EsqlStatsRequest request) - Specified by:
newNodeRequestin classTransportNodesAction<EsqlStatsRequest,EsqlStatsResponse, org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest, EsqlStatsResponse.NodeStatsResponse, Void>
-
newNodeResponse
protected EsqlStatsResponse.NodeStatsResponse newNodeResponse(StreamInput in, DiscoveryNode node) throws IOException - Specified by:
newNodeResponsein classTransportNodesAction<EsqlStatsRequest,EsqlStatsResponse, org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest, EsqlStatsResponse.NodeStatsResponse, Void> - Throws:
IOException
-
nodeOperation
protected EsqlStatsResponse.NodeStatsResponse nodeOperation(org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest request, Task task) - Specified by:
nodeOperationin classTransportNodesAction<EsqlStatsRequest,EsqlStatsResponse, org.elasticsearch.xpack.esql.plugin.EsqlStatsRequest.NodeStatsRequest, EsqlStatsResponse.NodeStatsResponse, Void>
-