public class TransportFieldStatsAction extends TransportBroadcastAction<FieldStatsRequest,FieldStatsResponse,FieldStatsShardRequest,FieldStatsShardResponse>
TransportBroadcastAction.AsyncBroadcastAction
clusterService, transportService
actionName, indexNameExpressionResolver, taskManager, threadPool
deprecationLogger, logger, settings
Constructor and Description |
---|
TransportFieldStatsAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
IndicesService indicesService) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
FieldStatsRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
FieldStatsRequest request,
java.lang.String[] concreteIndices) |
protected FieldStatsResponse |
newResponse(FieldStatsRequest request,
java.util.concurrent.atomic.AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected FieldStatsShardRequest |
newShardRequest(int numShards,
ShardRouting shard,
FieldStatsRequest request) |
protected FieldStatsShardResponse |
newShardResponse() |
protected FieldStatsShardResponse |
shardOperation(FieldStatsShardRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
FieldStatsRequest request,
java.lang.String[] concreteIndices)
Determines the shards this operation will be executed on.
|
doExecute, doExecute, shardOperation
execute, execute, execute, execute
logDeprecatedSetting, logRemovedSetting, nodeName
@Inject public TransportFieldStatsAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, IndicesService indicesService)
protected FieldStatsResponse newResponse(FieldStatsRequest request, java.util.concurrent.atomic.AtomicReferenceArray shardsResponses, ClusterState clusterState)
newResponse
in class TransportBroadcastAction<FieldStatsRequest,FieldStatsResponse,FieldStatsShardRequest,FieldStatsShardResponse>
protected FieldStatsShardRequest newShardRequest(int numShards, ShardRouting shard, FieldStatsRequest request)
protected FieldStatsShardResponse newShardResponse()
protected FieldStatsShardResponse shardOperation(FieldStatsShardRequest request)
protected GroupShardsIterator shards(ClusterState clusterState, FieldStatsRequest request, java.lang.String[] concreteIndices)
TransportBroadcastAction
shards
in class TransportBroadcastAction<FieldStatsRequest,FieldStatsResponse,FieldStatsShardRequest,FieldStatsShardResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, FieldStatsRequest request)
protected ClusterBlockException checkRequestBlock(ClusterState state, FieldStatsRequest request, java.lang.String[] concreteIndices)