public class TransportCountAction extends TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
TransportBroadcastOperationAction.AsyncBroadcastAction
clusterService, threadPool, transportService
actionName
componentSettings, logger, settings
Constructor and Description |
---|
TransportCountAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
IndicesService indicesService,
ScriptService scriptService,
CacheRecycler cacheRecycler,
PageCacheRecycler pageCacheRecycler,
BigArrays bigArrays,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
CountRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
CountRequest countRequest,
String[] concreteIndices) |
protected void |
doExecute(CountRequest request,
ActionListener<CountResponse> listener) |
protected String |
executor() |
protected CountRequest |
newRequest() |
protected CountResponse |
newResponse(CountRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected org.elasticsearch.action.count.ShardCountRequest |
newShardRequest() |
protected org.elasticsearch.action.count.ShardCountRequest |
newShardRequest(int numShards,
ShardRouting shard,
CountRequest request) |
protected org.elasticsearch.action.count.ShardCountResponse |
newShardResponse() |
protected org.elasticsearch.action.count.ShardCountResponse |
shardOperation(org.elasticsearch.action.count.ShardCountRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
CountRequest request,
String[] concreteIndices)
Determines the shards this operation will be executed on.
|
execute, execute, forceThreadedListener
nodeName
@Inject public TransportCountAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ScriptService scriptService, CacheRecycler cacheRecycler, PageCacheRecycler pageCacheRecycler, BigArrays bigArrays, ActionFilters actionFilters)
protected void doExecute(CountRequest request, ActionListener<CountResponse> listener)
doExecute
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected String executor()
executor
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected CountRequest newRequest()
newRequest
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected org.elasticsearch.action.count.ShardCountRequest newShardRequest()
newShardRequest
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected org.elasticsearch.action.count.ShardCountRequest newShardRequest(int numShards, ShardRouting shard, CountRequest request)
newShardRequest
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected org.elasticsearch.action.count.ShardCountResponse newShardResponse()
newShardResponse
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected GroupShardsIterator shards(ClusterState clusterState, CountRequest request, String[] concreteIndices)
TransportBroadcastOperationAction
shards
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, CountRequest request)
checkGlobalBlock
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, CountRequest countRequest, String[] concreteIndices)
checkRequestBlock
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected CountResponse newResponse(CountRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
newResponse
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
protected org.elasticsearch.action.count.ShardCountResponse shardOperation(org.elasticsearch.action.count.ShardCountRequest request) throws ElasticsearchException
shardOperation
in class TransportBroadcastOperationAction<CountRequest,CountResponse,org.elasticsearch.action.count.ShardCountRequest,org.elasticsearch.action.count.ShardCountResponse>
ElasticsearchException
Copyright © 2009–2015. All rights reserved.