Module org.elasticsearch.server
Class TransportBroadcastAction.AsyncBroadcastAction
java.lang.Object
org.elasticsearch.action.support.broadcast.TransportBroadcastAction.AsyncBroadcastAction
- Enclosing class:
TransportBroadcastAction<Request extends BroadcastRequest<Request>,Response extends BaseBroadcastResponse, ShardRequest extends BroadcastShardRequest, ShardResponse extends BroadcastShardResponse>
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAsyncBroadcastAction(Task task, Request request, ActionListener<Response> listener) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected voidonOperation(ShardRouting shard, int shardIndex, ShardResponse response) protected voidperformOperation(ShardIterator shardIt, ShardRouting shard, int shardIndex) protected voidsendShardRequest(DiscoveryNode node, ShardRequest shardRequest, ActionListener<ShardResponse> listener) voidstart()
-
Field Details
-
shardsResponses
-
-
Constructor Details
-
AsyncBroadcastAction
-
-
Method Details
-
start
public void start() -
performOperation
-
sendShardRequest
protected void sendShardRequest(DiscoveryNode node, ShardRequest shardRequest, ActionListener<ShardResponse> listener) -
onOperation
-
finishHim
protected void finishHim()
-