java.lang.Object
org.elasticsearch.common.component.AbstractComponent
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<Request,Response,ShardRequest,ShardResponse>
- Direct Known Subclasses:
- TransportClearIndicesCacheAction, TransportCountAction, TransportFlushAction, TransportGatewaySnapshotAction, TransportIndicesSegmentsAction, TransportIndicesStatsAction, TransportIndicesStatusAction, TransportOptimizeAction, TransportRefreshAction, TransportValidateQueryAction
public abstract class TransportBroadcastOperationAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse,ShardRequest extends BroadcastShardOperationRequest,ShardResponse extends BroadcastShardOperationResponse>
- extends TransportAction<Request,Response>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
clusterService
protected final ClusterService clusterService
transportService
protected final TransportService transportService
threadPool
protected final ThreadPool threadPool
TransportBroadcastOperationAction
protected TransportBroadcastOperationAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService)
doExecute
protected void doExecute(Request request,
ActionListener<Response> listener)
- Specified by:
doExecute
in class TransportAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse>
transportAction
protected abstract String transportAction()
executor
protected abstract String executor()
newRequest
protected abstract Request newRequest()
newResponse
protected abstract Response newResponse(Request request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState)
newShardRequest
protected abstract ShardRequest newShardRequest()
newShardRequest
protected abstract ShardRequest newShardRequest(ShardRouting shard,
Request request)
newShardResponse
protected abstract ShardResponse newShardResponse()
shardOperation
protected abstract ShardResponse shardOperation(ShardRequest request)
throws ElasticSearchException
- Throws:
ElasticSearchException
shards
protected abstract GroupShardsIterator shards(ClusterState clusterState,
Request request,
String[] concreteIndices)
accumulateExceptions
protected boolean accumulateExceptions()
ignoreException
protected boolean ignoreException(Throwable t)
ignoreNonActiveExceptions
protected boolean ignoreNonActiveExceptions()
checkGlobalBlock
protected abstract ClusterBlockException checkGlobalBlock(ClusterState state,
Request request)
checkRequestBlock
protected abstract ClusterBlockException checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices)
Copyright © 2009-2012. All Rights Reserved.