AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

AsyncProcess.AsyncRequestFutureImpl<CResult>
```
private final class AsyncProcess.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<Row>> initialActions

private long startTime

Fields
Modifier and Type	Field and Description
`private List<Action<Row>>`	`initialActions`
`private long`	`startTime`

Constructor Summary

Constructors
Constructor and Description
`AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable(List<Action<Row>> initialActions, long startTime)`

Method Summary

Methods
Modifier and Type	Method and Description
`private void`	`addReplicaActions(int index, Map<ServerName,MultiAction<Row>> actionsByServer, List<Action<Row>> unknownReplicaActions)` Add replica actions to action map by server.
`private void`	`addReplicaActionsAgain(Action<Row> action, Map<ServerName,MultiAction<Row>> 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<Row>> initialActions

Constructor Detail

AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

public AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable(List<Action<Row>> initialActions,
                                                              long startTime)

Method Detail

run
```
public void run()
```
Specified by:

run in interface Runnable

addReplicaActions

private void addReplicaActions(int index,
                     Map<ServerName,MultiAction<Row>> actionsByServer,
                     List<Action<Row>> 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<Row> action,
                          Map<ServerName,MultiAction<Row>> actionsByServer)

Class AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

startTime

initialActions

Constructor Detail

AsyncProcess.AsyncRequestFutureImpl.ReplicaCallIssuingRunnable

Method Detail

run

addReplicaActions

addReplicaActionsAgain