Package org.elasticsearch.action.support.broadcast

Class TransportBroadcastAction.AsyncBroadcastAction

java.lang.Object

org.elasticsearch.action.support.broadcast.TransportBroadcastAction.AsyncBroadcastAction

Enclosing class:

TransportBroadcastAction<Request extends BroadcastRequest<Request>,Response extends BroadcastResponse,ShardRequest extends BroadcastShardRequest,ShardResponse extends BroadcastShardResponse>

protected class TransportBroadcastAction.AsyncBroadcastAction
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicReferenceArray<Object>	shardsResponses

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsyncBroadcastAction(Task task, Request request, ActionListener<Response> listener)

Method Summary

Modifier and Type	Method	Description
protected void	finishHim()
protected void	onOperation(ShardRouting shard, int shardIndex, ShardResponse response)
protected void	performOperation(ShardIterator shardIt, ShardRouting shard, int shardIndex)
protected void	sendShardRequest(DiscoveryNode node, ShardRequest shardRequest, ActionListener<ShardResponse> listener)
protected AtomicReferenceArray<Object>	shardsResponses()
void	start()

Methods inherited from class java.lang.Object

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

Field Details

shardsResponses

protected final AtomicReferenceArray<Object> shardsResponses

Constructor Details

AsyncBroadcastAction

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

Method Details

start

public void start()

performOperation

protected void performOperation(ShardIterator shardIt,
 ShardRouting shard,
 int shardIndex)

sendShardRequest

protected void sendShardRequest(DiscoveryNode node,
 ShardRequest shardRequest,
 ActionListener<ShardResponse> listener)

onOperation

protected void onOperation(ShardRouting shard,
 int shardIndex,
 ShardResponse response)

shardsResponses

protected AtomicReferenceArray<Object> shardsResponses()

finishHim

protected void finishHim()