Module org.elasticsearch.server

Package org.elasticsearch.action.admin.cluster.node.tasks.get

Class TransportGetTaskAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<GetTaskRequest,GetTaskResponse>

org.elasticsearch.action.admin.cluster.node.tasks.get.TransportGetTaskAction

public class TransportGetTaskAction
extends HandledTransportAction<GetTaskRequest,GetTaskResponse>

ActionType to get a single task. If the task isn't running then it'll try to request the status from request index. The general flow is:

• If this isn't being executed on the node to which the requested TaskId belongs then move to that node.
• Look up the task and return it if it exists
• If it doesn't then look up the task from the results index

Field Summary

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

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportGetTaskAction(ThreadPool threadPool, TransportService transportService, ActionFilters actionFilters, ClusterService clusterService, Client client, NamedXContentRegistry xContentRegistry)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task thisTask, GetTaskRequest request, ActionListener<GetTaskResponse> listener)

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

execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportGetTaskAction

@Inject
public TransportGetTaskAction(ThreadPool threadPool,
 TransportService transportService,
 ActionFilters actionFilters,
 ClusterService clusterService,
 Client client,
 NamedXContentRegistry xContentRegistry)

Method Details

doExecute

protected void doExecute(Task thisTask,
 GetTaskRequest request,
 ActionListener<GetTaskResponse> listener)

Specified by:

doExecute in class TransportAction<GetTaskRequest,GetTaskResponse>