@InterfaceAudience.Private public class RpcRetryingCallerWithReadReplicas extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected ClusterConnection |
cConnection |
protected Configuration |
conf |
protected Get |
get |
protected java.util.concurrent.ExecutorService |
pool |
protected TableName |
tableName |
protected int |
timeBeforeReplicas |
Constructor and Description |
---|
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory,
TableName tableName,
ClusterConnection cConnection,
Get get,
java.util.concurrent.ExecutorService pool,
int retries,
int callTimeout,
int timeBeforeReplicas) |
Modifier and Type | Method and Description |
---|---|
Result |
call(int operationTimeout)
Algo:
- we put the query into the execution pool.
|
protected final java.util.concurrent.ExecutorService pool
protected final ClusterConnection cConnection
protected final Configuration conf
protected final Get get
protected final TableName tableName
protected final int timeBeforeReplicas
public RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory, TableName tableName, ClusterConnection cConnection, Get get, java.util.concurrent.ExecutorService pool, int retries, int callTimeout, int timeBeforeReplicas)
public Result call(int operationTimeout) throws DoNotRetryIOException, java.io.InterruptedIOException, RetriesExhaustedException
DoNotRetryIOException
java.io.InterruptedIOException
RetriesExhaustedException