org.elasticsearch.action.admin.indices.cache.clear

Class TransportClearIndicesCacheAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

org.elasticsearch.action.admin.indices.cache.clear.TransportClearIndicesCacheAction

public class TransportClearIndicesCacheAction
extends TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

Indices clear cache action.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

TransportBroadcastOperationAction.AsyncBroadcastAction

Field Summary

Fields inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

clusterService, threadPool, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportClearIndicesCacheAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, IndicesTermsFilterCache termsFilterCache, IndicesQueryCache indicesQueryCache, ActionFilters actionFilters)

Method Summary

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.

Methods inherited from class org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction

doExecute

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, forceThreadedListener

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportClearIndicesCacheAction

@Inject
public TransportClearIndicesCacheAction(Settings settings,
                                                ThreadPool threadPool,
                                                ClusterService clusterService,
                                                TransportService transportService,
                                                IndicesService indicesService,
                                                IndicesTermsFilterCache termsFilterCache,
                                                IndicesQueryCache indicesQueryCache,
                                                ActionFilters actionFilters)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

newRequest

protected ClearIndicesCacheRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

newResponse

protected ClearIndicesCacheResponse newResponse(ClearIndicesCacheRequest request,
                                                AtomicReferenceArray shardsResponses,
                                                ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

newShardRequest

protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest newShardRequest(int numShards,
                                                                                                           ShardRouting shard,
                                                                                                           ClearIndicesCacheRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

newShardResponse

protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

shardOperation

protected org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse shardOperation(org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest request)
                                                                                                    throws ElasticsearchException

Specified by:

shardOperation in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

Throws:

ElasticsearchException

shards

protected GroupShardsIterator shards(ClusterState clusterState,
                                     ClearIndicesCacheRequest request,
                                     String[] concreteIndices)

The refresh request works against *all* shards.

Specified by:

shards in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 ClearIndicesCacheRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  ClearIndicesCacheRequest request,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<ClearIndicesCacheRequest,ClearIndicesCacheResponse,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheRequest,org.elasticsearch.action.admin.indices.cache.clear.ShardClearIndicesCacheResponse>