org.elasticsearch.action.exists

Class TransportExistsAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

org.elasticsearch.action.exists.TransportExistsAction

public class TransportExistsAction
extends TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

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
TransportExistsAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ScriptService scriptService, CacheRecycler cacheRecycler, PageCacheRecycler pageCacheRecycler, BigArrays bigArrays, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected ClusterBlockException	checkGlobalBlock(ClusterState state, ExistsRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, ExistsRequest countRequest, String[] concreteIndices)
protected void	doExecute(ExistsRequest request, ActionListener<ExistsResponse> listener)
protected String	executor()
protected ExistsRequest	newRequest()
protected ExistsResponse	newResponse(ExistsRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected org.elasticsearch.action.exists.ShardExistsRequest	newShardRequest()
protected org.elasticsearch.action.exists.ShardExistsRequest	newShardRequest(int numShards, ShardRouting shard, ExistsRequest request)
protected org.elasticsearch.action.exists.ShardExistsResponse	newShardResponse()
protected org.elasticsearch.action.exists.ShardExistsResponse	shardOperation(org.elasticsearch.action.exists.ShardExistsRequest request)
protected GroupShardsIterator	shards(ClusterState clusterState, ExistsRequest request, String[] concreteIndices) Determines the shards this operation will be executed on.

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

TransportExistsAction

@Inject
public TransportExistsAction(Settings settings,
                                     ThreadPool threadPool,
                                     ClusterService clusterService,
                                     TransportService transportService,
                                     IndicesService indicesService,
                                     ScriptService scriptService,
                                     CacheRecycler cacheRecycler,
                                     PageCacheRecycler pageCacheRecycler,
                                     BigArrays bigArrays,
                                     ActionFilters actionFilters)

Method Detail

doExecute

protected void doExecute(ExistsRequest request,
                         ActionListener<ExistsResponse> listener)

Overrides:

doExecute in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

executor

protected String executor()

Specified by:

executor in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

newRequest

protected ExistsRequest newRequest()

Specified by:

newRequest in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

newShardRequest

protected org.elasticsearch.action.exists.ShardExistsRequest newShardRequest()

Specified by:

newShardRequest in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

newShardRequest

protected org.elasticsearch.action.exists.ShardExistsRequest newShardRequest(int numShards,
                                                                             ShardRouting shard,
                                                                             ExistsRequest request)

Specified by:

newShardRequest in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

newShardResponse

protected org.elasticsearch.action.exists.ShardExistsResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

shards

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

Description copied from class: TransportBroadcastOperationAction

Determines the shards this operation will be executed on. The operation is executed once per shard iterator, typically on the first shard in it. If the operation fails, it will be retried on the next shard in the iterator.

Specified by:

shards in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 ExistsRequest request)

Specified by:

checkGlobalBlock in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  ExistsRequest countRequest,
                                                  String[] concreteIndices)

Specified by:

checkRequestBlock in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

newResponse

protected ExistsResponse newResponse(ExistsRequest request,
                                     AtomicReferenceArray shardsResponses,
                                     ClusterState clusterState)

Specified by:

newResponse in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

shardOperation

protected org.elasticsearch.action.exists.ShardExistsResponse shardOperation(org.elasticsearch.action.exists.ShardExistsRequest request)
                                                                      throws ElasticsearchException

Specified by:

shardOperation in class TransportBroadcastOperationAction<ExistsRequest,ExistsResponse,org.elasticsearch.action.exists.ShardExistsRequest,org.elasticsearch.action.exists.ShardExistsResponse>

Throws:

ElasticsearchException