Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Class and Description |
---|---|
class |
RpcRetryingCallerImpl<T>
Runs an rpc'ing
RetryingCallable . |
Modifier and Type | Field and Description |
---|---|
private RpcRetryingCaller<Result[]> |
ScannerCallableWithReplicas.caller |
(package private) RpcRetryingCaller<Result[]> |
ScannerCallableWithReplicas.RetryingRPC.caller |
protected RpcRetryingCaller<Result[]> |
ClientScanner.caller |
private RpcRetryingCaller<T> |
ResultBoundedCompletionService.QueueingFuture.retryingCaller |
Modifier and Type | Method and Description |
---|---|
protected RpcRetryingCaller<AbstractResponse> |
AsyncProcess.createCaller(CancellableRegionServerCallable callable,
int rpcTimeout)
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 |
---|---|
private Result[] |
ClientScanner.call(ScannerCallableWithReplicas callable,
RpcRetryingCaller<Result[]> caller,
int scannerTimeout,
boolean updateCurrentRegion) |
Constructor and Description |
---|
ScannerCallableWithReplicas(TableName tableName,
ClusterConnection cConnection,
ScannerCallable baseCallable,
ExecutorService pool,
int timeBeforeReplicas,
Scan scan,
int retries,
int readRpcTimeout,
int scannerTimeout,
int caching,
org.apache.hadoop.conf.Configuration conf,
RpcRetryingCaller<Result[]> caller) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.