Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Class and Description |
---|---|
class |
StatsTrackingRpcRetryingCaller<T>
An
RpcRetryingCaller that will update the per-region stats for the call on return,
if stats are available |
Modifier and Type | Field and Description |
---|---|
protected RpcRetryingCaller<Result[]> |
ClientScanner.caller |
Modifier and Type | Method and Description |
---|---|
RpcRetryingCaller<java.lang.Void> |
TestFastFailWithoutTestUtil.getRpcRetryingCaller(int pauseTime,
int retries,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor) |
<T> RpcRetryingCaller<T> |
RpcRetryingCallerFactory.newCaller()
Create a new RetryingCaller with configured rpc timeout.
|
<T> RpcRetryingCaller<T> |
TestClientScanner.MockRpcRetryingCallerFactory.newCaller() |
<T> RpcRetryingCaller<T> |
RpcRetryingCallerFactory.newCaller(int rpcTimeout)
Create a new RetryingCaller with specific rpc timeout.
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallScanner.SmallScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller) |
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallReversedScanner.SmallReversedScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller,
boolean isFirstRegionToLocate) |