org.elasticsearch.action.admin.cluster.node.hotthreads
Class TransportNodesHotThreadsAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.nodes.TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>
              org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction

public class TransportNodesHotThreadsAction
extends TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Field Summary

Fields inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

clusterName, clusterService, transportService

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

threadPool

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

componentSettings, logger, settings

Constructor Summary

TransportNodesHotThreadsAction(Settings settings, ClusterName clusterName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService)

Method Summary

protected boolean	accumulateExceptions()
protected String	executor()
protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest	newNodeRequest()
protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest	newNodeRequest(String nodeId, NodesHotThreadsRequest request)
protected NodeHotThreads	newNodeResponse()
protected NodesHotThreadsRequest	newRequest()
protected NodesHotThreadsResponse	newResponse(NodesHotThreadsRequest request, AtomicReferenceArray responses)
protected NodeHotThreads	nodeOperation(org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest request)
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.nodes.TransportNodesOperationAction

doExecute, filterNodeIds, transportCompress

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

execute, execute

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

nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportNodesHotThreadsAction

@Inject
public TransportNodesHotThreadsAction(Settings settings,
                                             ClusterName clusterName,
                                             ThreadPool threadPool,
                                             ClusterService clusterService,
                                             TransportService transportService)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newResponse

protected NodesHotThreadsResponse newResponse(NodesHotThreadsRequest request,
                                              AtomicReferenceArray responses)

Specified by:

newResponse in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newRequest

protected NodesHotThreadsRequest newRequest()

Specified by:

newRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeRequest

protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest newNodeRequest()

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeRequest

protected org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest newNodeRequest(String nodeId,
                                                                                                                           NodesHotThreadsRequest request)

Specified by:

newNodeRequest in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

newNodeResponse

protected NodeHotThreads newNodeResponse()

Specified by:

newNodeResponse in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

nodeOperation

protected NodeHotThreads nodeOperation(org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest request)
                                throws ElasticSearchException

Specified by:

nodeOperation in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>

Throws:

ElasticSearchException

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportNodesOperationAction<NodesHotThreadsRequest,NodesHotThreadsResponse,org.elasticsearch.action.admin.cluster.node.hotthreads.TransportNodesHotThreadsAction.NodeRequest,NodeHotThreads>