| 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 |
private RpcRetryingCaller<Result[]> |
ScannerCallableWithReplicas.caller |
(package private) RpcRetryingCaller<Result[]> |
ScannerCallableWithReplicas.RetryingRPC.caller |
private RpcRetryingCaller<T> |
ResultBoundedCompletionService.QueueingFuture.retryingCaller |
| Modifier and Type | Method and Description |
|---|---|
protected RpcRetryingCaller<MultiResponse> |
AsyncProcess.createCaller(MultiServerCallable<Row> callable)
Create a caller.
|
<T> RpcRetryingCaller<T> |
RpcRetryingCallerFactory.newCaller()
Create a new RetryingCaller with configured rpc timeout.
|
<T> RpcRetryingCaller<T> |
RpcRetryingCallerFactory.newCaller(int rpcTimeout)
Create a new RetryingCaller with specific rpc timeout.
|
| Modifier and Type | Method and Description |
|---|---|
(package private) Result[] |
ClientScanner.call(ScannerCallableWithReplicas callable,
RpcRetryingCaller<Result[]> caller,
int scannerTimeout) |
ScannerCallableWithReplicas |
ClientSmallScanner.SmallScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCaller<Result[]> caller) |
ScannerCallableWithReplicas |
ClientSmallReversedScanner.SmallReversedScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCaller<Result[]> caller,
boolean isFirstRegionToLocate) |
| Constructor and Description |
|---|
ScannerCallableWithReplicas(TableName tableName,
ClusterConnection cConnection,
ScannerCallable baseCallable,
ExecutorService pool,
int timeBeforeReplicas,
Scan scan,
int retries,
int scannerTimeout,
int caching,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCaller<Result[]> caller) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.