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 and Description
private List<Action>	initialActions
private long	startTime

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

startTime

private final long startTime

initialActions

private final List<Action> initialActions

Constructor Detail

ReplicaCallIssuingRunnable

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

Method Detail

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)