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
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AsyncBroadcastAction(Task task, Request request, ActionListener<Response> listener)
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
void
start()
-
-
-
Constructor Detail
-
AsyncBroadcastAction
protected AsyncBroadcastAction(Task task, Request request, ActionListener<Response> listener)
-
-
Method Detail
-
start
public void start()
-
performOperation
protected void performOperation(ShardIterator shardIt, ShardRouting shard, int shardIndex)
-
onOperation
protected void onOperation(ShardRouting shard, int shardIndex, ShardResponse response)
-
finishHim
protected void finishHim()
-
-