java.lang.Object
org.elasticsearch.common.component.AbstractComponent
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.nodes.TransportNodesOperationAction<Request,Response,NodeRequest,NodeResponse>
- Direct Known Subclasses:
- TransportNodesHotThreadsAction, TransportNodesInfoAction, TransportNodesListGatewayMetaState, TransportNodesListGatewayStartedShards, TransportNodesListShardStoreMetaData, TransportNodesRestartAction, TransportNodesStatsAction
public abstract class TransportNodesOperationAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse,NodeRequest extends NodeOperationRequest,NodeResponse extends NodeOperationResponse>
- extends TransportAction<Request,Response>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
clusterName
protected final ClusterName clusterName
clusterService
protected final ClusterService clusterService
transportService
protected final TransportService transportService
TransportNodesOperationAction
@Inject
public TransportNodesOperationAction(Settings settings,
ClusterName clusterName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService)
doExecute
protected void doExecute(Request request,
ActionListener<Response> listener)
- Specified by:
doExecute
in class TransportAction<Request extends NodesOperationRequest,Response extends NodesOperationResponse>
transportAction
protected abstract String transportAction()
transportCompress
protected boolean transportCompress()
executor
protected abstract String executor()
newRequest
protected abstract Request newRequest()
newResponse
protected abstract Response newResponse(Request request,
AtomicReferenceArray nodesResponses)
newNodeRequest
protected abstract NodeRequest newNodeRequest()
newNodeRequest
protected abstract NodeRequest newNodeRequest(String nodeId,
Request request)
newNodeResponse
protected abstract NodeResponse newNodeResponse()
nodeOperation
protected abstract NodeResponse nodeOperation(NodeRequest request)
throws ElasticSearchException
- Throws:
ElasticSearchException
accumulateExceptions
protected abstract boolean accumulateExceptions()
filterNodeIds
protected String[] filterNodeIds(DiscoveryNodes nodes,
String[] nodesIds)
Copyright © 2009-2012. All Rights Reserved.