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 java.lang.Object
-
Field Summary
Fields Modifier and Type Field Description protected java.util.concurrent.atomic.AtomicReferenceArray
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 java.util.concurrent.atomic.AtomicReferenceArray
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 java.util.concurrent.atomic.AtomicReferenceArray shardsResponses
-
-
Constructor Details
-
AsyncBroadcastAction
-
-
Method Details
-
start
public void start() -
performOperation
-
onOperation
-
shardsResponses
protected java.util.concurrent.atomic.AtomicReferenceArray shardsResponses() -
finishHim
protected void finishHim()
-