public class TransportClearIndicesCacheAction extends TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
TransportBroadcastOperationAction.AsyncBroadcastAction
clusterService, threadPool, transportService
actionName
componentSettings, logger, settings
Constructor and Description |
---|
TransportClearIndicesCacheAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
IndicesService indicesService,
IndicesTermsFilterCache termsFilterCache,
IndicesQueryCache indicesQueryCache,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
checkGlobalBlock(ClusterState state,
ClearIndicesCacheRequest request) |
protected ClusterBlockException |
checkRequestBlock(ClusterState state,
ClearIndicesCacheRequest request,
String[] concreteIndices) |
protected String |
executor() |
protected ClearIndicesCacheRequest |
newRequest() |
protected ClearIndicesCacheResponse |
newResponse(ClearIndicesCacheRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest |
newShardRequest() |
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest |
newShardRequest(int numShards,
ShardRouting shard,
ClearIndicesCacheRequest request) |
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse |
newShardResponse() |
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse |
shardOperation(org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest request) |
protected GroupShardsIterator |
shards(ClusterState clusterState,
ClearIndicesCacheRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
doExecute
execute, execute, forceThreadedListener
nodeName
@Inject public TransportClearIndicesCacheAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, IndicesTermsFilterCache termsFilterCache, IndicesQueryCache indicesQueryCache, ActionFilters actionFilters)
protected String executor()
executor
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected ClearIndicesCacheRequest newRequest()
newRequest
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected ClearIndicesCacheResponse newResponse(ClearIndicesCacheRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
newResponse
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest newShardRequest()
newShardRequest
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest newShardRequest(int numShards, ShardRouting shard, ClearIndicesCacheRequest request)
newShardRequest
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse newShardResponse()
newShardResponse
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse shardOperation(org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest request) throws ElasticsearchException
shardOperation
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
ElasticsearchException
protected GroupShardsIterator shards(ClusterState clusterState, ClearIndicesCacheRequest request, String[] concreteIndices)
shards
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected ClusterBlockException checkGlobalBlock(ClusterState state, ClearIndicesCacheRequest request)
checkGlobalBlock
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
protected ClusterBlockException checkRequestBlock(ClusterState state, ClearIndicesCacheRequest request, String[] concreteIndices)
checkRequestBlock
in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>
Copyright © 2009–2015. All rights reserved.