Package org.elasticsearch.action.support.replication

Class TransportBroadcastReplicationAction<Request extends BroadcastRequest<Request>,Response extends BroadcastResponse,ShardRequest extends ReplicationRequest<ShardRequest>,ShardResponse extends ReplicationResponse>

java.lang.Object

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

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

org.elasticsearch.action.support.replication.TransportBroadcastReplicationAction<Request,Response,ShardRequest,ShardResponse>

Direct Known Subclasses:

TransportFlushAction, TransportRefreshAction

public abstract class TransportBroadcastReplicationAction<Request extends BroadcastRequest<Request>,Response extends BroadcastResponse,ShardRequest extends ReplicationRequest<ShardRequest>,ShardResponse extends ReplicationResponse>
extends HandledTransportAction<Request,Response>

Base class for requests that should be executed on all shards of an index or several indices. This action sends shard requests to all primary shards of the indices and they are then replicated like write requests

Field Summary

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

actionName, localConnection, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportBroadcastReplicationAction(String name, Writeable.Reader<Request> requestReader, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, TransportReplicationAction replicatedBroadcastShardAction)

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task task, Request request, ActionListener<Response> listener)
protected abstract BroadcastResponse	newResponse(int successfulShards, int failedShards, int totalNumCopies, List<DefaultShardOperationFailedException> shardFailures)
protected abstract ShardRequest	newShardRequest(Request request, ShardId shardId)
protected abstract ShardResponse	newShardResponse()
protected void	shardExecute(Task task, Request request, ShardId shardId, ActionListener<ShardResponse> shardActionListener)
protected List<ShardId>	shards(Request request, ClusterState clusterState)

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

execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportBroadcastReplicationAction

public TransportBroadcastReplicationAction(String name,
 Writeable.Reader<Request> requestReader,
 ClusterService clusterService,
 TransportService transportService,
 ActionFilters actionFilters,
 IndexNameExpressionResolver indexNameExpressionResolver,
 TransportReplicationAction replicatedBroadcastShardAction)

Method Details

doExecute

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

Specified by:

doExecute in class TransportAction<Request extends BroadcastRequest<Request>,Response extends BroadcastResponse>

shardExecute

protected void shardExecute(Task task,
 Request request,
 ShardId shardId,
 ActionListener<ShardResponse> shardActionListener)

shards

protected List<ShardId> shards(Request request,
 ClusterState clusterState)

Returns:

all shard ids the request should run on

newShardResponse

protected abstract ShardResponse newShardResponse()

newShardRequest

protected abstract ShardRequest newShardRequest(Request request,
 ShardId shardId)

newResponse

protected abstract BroadcastResponse newResponse(int successfulShards,
 int failedShards,
 int totalNumCopies,
 List<DefaultShardOperationFailedException> shardFailures)