public class TransportFieldStatsTransportAction extends TransportBroadcastOperationAction<FieldStatsRequest,FieldStatsResponse,FieldStatsShardRequest,FieldStatsShardResponse>
TransportBroadcastOperationAction.AsyncBroadcastAction
clusterService, threadPool, transportService
actionName
componentSettings, logger, settings
Constructor and Description |
---|
TransportFieldStatsTransportAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters,
IndicesService indicesService) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
FieldStatsRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
FieldStatsRequest request,
String[] concreteIndices) |
protected String |
executor() |
protected FieldStatsRequest |
newRequest() |
protected FieldStatsResponse |
newResponse(FieldStatsRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected FieldStatsShardRequest |
newShardRequest() |
protected FieldStatsShardRequest |
newShardRequest(int numShards,
ShardRouting shard,
FieldStatsRequest request) |
protected FieldStatsShardResponse |
newShardResponse() |
protected FieldStatsShardResponse |
shardOperation(FieldStatsShardRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
FieldStatsRequest request,
String[] concreteIndices)
Determines the shards this operation will be executed on.
|
doExecute
execute, execute, forceThreadedListener
nodeName
@Inject public TransportFieldStatsTransportAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndicesService indicesService)
protected String executor()
protected FieldStatsRequest newRequest()
protected FieldStatsResponse newResponse(FieldStatsRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected FieldStatsShardRequest newShardRequest()
protected FieldStatsShardRequest newShardRequest(int numShards, ShardRouting shard, FieldStatsRequest request)
protected FieldStatsShardResponse newShardResponse()
protected FieldStatsShardResponse shardOperation(FieldStatsShardRequest request) throws ElasticsearchException
shardOperation
in class TransportBroadcastOperationAction<FieldStatsRequest,FieldStatsResponse,FieldStatsShardRequest,FieldStatsShardResponse>
ElasticsearchException
protected GroupShardsIterator shards(ClusterState clusterState, FieldStatsRequest request, String[] concreteIndices)
TransportBroadcastOperationAction
protected ClusterBlockException checkGlobalBlock(ClusterState state, FieldStatsRequest request)
protected ClusterBlockException checkRequestBlock(ClusterState state, FieldStatsRequest request, String[] concreteIndices)
Copyright © 2009–2015. All rights reserved.