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

Class TransportGetTaskAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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>

Action 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, indexNameExpressionResolver, taskManager, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportGetTaskAction(Settings settings, ThreadPool threadPool, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, ClusterService clusterService, Client client, NamedXContentRegistry xContentRegistry)

Method Summary

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

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

execute, execute, execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportGetTaskAction

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

Method Detail

doExecute

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

Specified by:

doExecute in class TransportAction<GetTaskRequest,GetTaskResponse>

doExecute

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

Overrides:

doExecute in class TransportAction<GetTaskRequest,GetTaskResponse>