org.elasticsearch.action.support.broadcast
Class TransportBroadcastOperationAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse,ShardRequest extends BroadcastShardOperationRequest,ShardResponse extends BroadcastShardOperationResponse>

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.broadcast.TransportBroadcastOperationAction<Request,Response,ShardRequest,ShardResponse>

Direct Known Subclasses:

TransportClearIndicesCacheAction, TransportCountAction, TransportFlushAction, TransportGatewaySnapshotAction, TransportIndicesSegmentsAction, TransportIndicesStatsAction, TransportIndicesStatusAction, TransportOptimizeAction, TransportRefreshAction, TransportValidateQueryAction

public abstract class TransportBroadcastOperationAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse,ShardRequest extends BroadcastShardOperationRequest,ShardResponse extends BroadcastShardOperationResponse>
extends TransportAction<Request,Response>

Field Summary

protected ClusterService	clusterService
protected ThreadPool	threadPool
protected TransportService	transportService

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

componentSettings, logger, settings

Constructor Summary

protected

TransportBroadcastOperationAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService)

Method Summary

protected boolean	accumulateExceptions()
protected abstract ClusterBlockException	checkGlobalBlock(ClusterState state, Request request)
protected abstract ClusterBlockException	checkRequestBlock(ClusterState state, Request request, String[] concreteIndices)
protected void	doExecute(Request request, ActionListener<Response> listener)
protected abstract String	executor()
protected boolean	ignoreException(Throwable t)
protected boolean	ignoreNonActiveExceptions()
protected abstract Request	newRequest()
protected abstract Response	newResponse(Request request, AtomicReferenceArray shardsResponses, ClusterState clusterState)
protected abstract ShardRequest	newShardRequest()
protected abstract ShardRequest	newShardRequest(ShardRouting shard, Request request)
protected abstract ShardResponse	newShardResponse()
protected abstract ShardResponse	shardOperation(ShardRequest request)
protected abstract GroupShardsIterator	shards(ClusterState clusterState, Request request, String[] concreteIndices)
protected abstract String	transportAction()

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

execute, execute

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

Field Detail

clusterService

protected final ClusterService clusterService

transportService

protected final TransportService transportService

threadPool

protected final ThreadPool threadPool

Constructor Detail

TransportBroadcastOperationAction

protected TransportBroadcastOperationAction(Settings settings,
                                            ThreadPool threadPool,
                                            ClusterService clusterService,
                                            TransportService transportService)

Method Detail

doExecute

protected void doExecute(Request request,
                         ActionListener<Response> listener)

Specified by:

doExecute in class TransportAction<Request extends BroadcastOperationRequest,Response extends BroadcastOperationResponse>

transportAction

protected abstract String transportAction()

executor

protected abstract String executor()

newRequest

protected abstract Request newRequest()

newResponse

protected abstract Response newResponse(Request request,
                                        AtomicReferenceArray shardsResponses,
                                        ClusterState clusterState)

newShardRequest

protected abstract ShardRequest newShardRequest()

newShardRequest

protected abstract ShardRequest newShardRequest(ShardRouting shard,
                                                Request request)

newShardResponse

protected abstract ShardResponse newShardResponse()

shardOperation

protected abstract ShardResponse shardOperation(ShardRequest request)
                                                                                 throws ElasticSearchException

Throws:

ElasticSearchException

shards

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

accumulateExceptions

protected boolean accumulateExceptions()

ignoreException

protected boolean ignoreException(Throwable t)

ignoreNonActiveExceptions

protected boolean ignoreNonActiveExceptions()

checkGlobalBlock

protected abstract ClusterBlockException checkGlobalBlock(ClusterState state,
                                                          Request request)

checkRequestBlock

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