public class TransportPercolateAction extends TransportBroadcastOperationAction<PercolateRequest,PercolateResponse,PercolateShardRequest,PercolateShardResponse>
TransportBroadcastOperationAction.AsyncBroadcastAction
clusterService, threadPool, transportService
actionName
componentSettings, logger, settings
Constructor and Description |
---|
TransportPercolateAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
PercolatorService percolatorService,
TransportGetAction getAction,
ActionFilters actionFilters) |
execute, execute, forceThreadedListener
nodeName
@Inject public TransportPercolateAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, PercolatorService percolatorService, TransportGetAction getAction, ActionFilters actionFilters)
protected void doExecute(PercolateRequest request, ActionListener<PercolateResponse> listener)
protected String executor()
protected PercolateRequest newRequest()
protected ClusterBlockException checkGlobalBlock(ClusterState state, PercolateRequest request)
protected ClusterBlockException checkRequestBlock(ClusterState state, PercolateRequest request, String[] concreteIndices)
protected PercolateResponse newResponse(PercolateRequest request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
public static PercolateResponse reduce(PercolateRequest request, AtomicReferenceArray shardsResponses, PercolatorService percolatorService)
protected PercolateShardRequest newShardRequest()
protected PercolateShardRequest newShardRequest(int numShards, ShardRouting shard, PercolateRequest request)
protected PercolateShardResponse newShardResponse()
protected GroupShardsIterator shards(ClusterState clusterState, PercolateRequest request, String[] concreteIndices)
TransportBroadcastOperationAction
shards
in class TransportBroadcastOperationAction<PercolateRequest,PercolateResponse,PercolateShardRequest,PercolateShardResponse>
protected PercolateShardResponse shardOperation(PercolateShardRequest request) throws ElasticsearchException
shardOperation
in class TransportBroadcastOperationAction<PercolateRequest,PercolateResponse,PercolateShardRequest,PercolateShardResponse>
ElasticsearchException
Copyright © 2009–2015. All rights reserved.