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>
-
Field Summary
-
Constructor Summary
ModifierConstructorDescriptionprotected
AsyncBroadcastAction
(Task task, Request request, ActionListener<Response> listener) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected void
onOperation
(ShardRouting shard, int shardIndex, ShardResponse response) protected void
performOperation
(ShardIterator shardIt, ShardRouting shard, int shardIndex) protected AtomicReferenceArray<Object>
void
start()
-
Field Details
-
shardsResponses
-
-
Constructor Details
-
AsyncBroadcastAction
-
-
Method Details
-
start
public void start() -
performOperation
-
onOperation
-
shardsResponses
-
finishHim
protected void finishHim()
-