public abstract class TransportBroadcastOperationAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse,ShardRequest extends BroadcastShardOperationRequest,ShardResponse extends BroadcastShardOperationResponse> extends TransportAction<Request,Response>
Modifier and Type | Class and Description |
---|---|
protected class |
TransportBroadcastOperationAction.AsyncBroadcastAction |
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected ThreadPool |
threadPool |
protected TransportService |
transportService |
actionName
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportBroadcastOperationAction(Settings settings,
String actionName,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected abstract ClusterBlockException |
checkGlobalBlock(ClusterState state,
Request request) |
protected abstract ClusterBlockException |
checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices) |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract String |
executor() |
protected abstract Request |
newRequest() |
protected abstract Response |
newResponse(Request request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected abstract ShardRequest |
newShardRequest() |
protected abstract ShardRequest |
newShardRequest(int numShards,
ShardRouting shard,
Request request) |
protected abstract ShardResponse |
newShardResponse() |
protected abstract ShardResponse |
shardOperation(ShardRequest request) |
protected abstract GroupShardsIterator |
shards(ClusterState clusterState,
Request request,
String[] concreteIndices)
Determines the shards this operation will be executed on.
|
execute, execute, forceThreadedListener
nodeName
protected final ThreadPool threadPool
protected final ClusterService clusterService
protected final TransportService transportService
protected TransportBroadcastOperationAction(Settings settings, String actionName, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters)
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse>
protected abstract String executor()
protected abstract Request newRequest()
protected abstract Response newResponse(Request request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected abstract ShardRequest newShardRequest()
protected abstract ShardRequest newShardRequest(int numShards, ShardRouting shard, Request request)
protected abstract ShardResponse newShardResponse()
protected abstract ShardResponse shardOperation(ShardRequest request) throws ElasticsearchException
ElasticsearchException
protected abstract GroupShardsIterator shards(ClusterState clusterState, Request request, String[] concreteIndices)
protected abstract ClusterBlockException checkGlobalBlock(ClusterState state, Request request)
protected abstract ClusterBlockException checkRequestBlock(ClusterState state, Request request, String[] concreteIndices)
Copyright © 2009–2015. All rights reserved.