Package org.apache.hadoop.hbase.client

Class AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

AsyncRequestFutureImpl<CResult>

private final class AsyncRequestFutureImpl.ReplicaCallIssuingRunnable
extends Object
implements Runnable

Runnable (that can be submitted to thread pool) that waits for when it's time to issue replica calls, finds region replicas, groups the requests by replica and issues the calls (on separate threads, via sendMultiAction). This is done on a separate thread because we don't want to wait on user thread for our asynchronous call, and usually we have to wait before making replica calls.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<Action>	initialActions
private final long	startTime

Constructor Summary

Constructors

Constructor	Description
ReplicaCallIssuingRunnable(List<Action> initialActions, long startTime)

Method Summary

Modifier and Type	Method	Description
private void	addReplicaActions(int index, Map<ServerName,MultiAction> actionsByServer, List<Action> unknownReplicaActions)	Add replica actions to action map by server.
private void	addReplicaActionsAgain(Action action, Map<ServerName,MultiAction> actionsByServer)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

startTime

private final long startTime

initialActions

private final List<Action> initialActions

Constructor Details

ReplicaCallIssuingRunnable

public ReplicaCallIssuingRunnable(List<Action> initialActions,
 long startTime)

Method Details

run

public void run()

Specified by:

run in interface Runnable

addReplicaActions

private void addReplicaActions(int index,
 Map<ServerName,MultiAction> actionsByServer,
 List<Action> unknownReplicaActions)

Add replica actions to action map by server.

Parameters:

index - Index of the original action.

actionsByServer - The map by server to add it to.

addReplicaActionsAgain

private void addReplicaActionsAgain(Action action,
 Map<ServerName,MultiAction> actionsByServer)