Package org.elasticsearch.action.support.broadcast

Class TransportBroadcastAction.AsyncBroadcastAction

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 

Field Summary

Fields

Modifier and Type	Field	Description
protected	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	shardsResponses()
void	start()

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Details

shardsResponses

protected final  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)

onOperation

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

shardsResponses

protected  shardsResponses()

finishHim

protected void finishHim()