@InterfaceAudience.Private public class RpcRetryingCallerFactory extends java.lang.Object
RpcRetryingCaller
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
static java.lang.String |
CUSTOM_CALLER_CONF_KEY
Configuration key for a custom
RpcRetryingCaller |
Constructor and Description |
---|
RpcRetryingCallerFactory(Configuration conf) |
RpcRetryingCallerFactory(Configuration conf,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor) |
Modifier and Type | Method and Description |
---|---|
static RpcRetryingCallerFactory |
instantiate(Configuration configuration) |
static RpcRetryingCallerFactory |
instantiate(Configuration configuration,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor,
ServerStatisticTracker stats) |
static RpcRetryingCallerFactory |
instantiate(Configuration configuration,
ServerStatisticTracker stats) |
<T> RpcRetryingCaller<T> |
newCaller()
Create a new RetryingCaller with configured rpc timeout.
|
<T> RpcRetryingCaller<T> |
newCaller(int rpcTimeout)
Create a new RetryingCaller with specific rpc timeout.
|
void |
setStatisticTracker(ServerStatisticTracker statisticTracker)
Set the tracker that should be used for tracking statistics about the server
|
public static final java.lang.String CUSTOM_CALLER_CONF_KEY
RpcRetryingCaller
protected final Configuration conf
public RpcRetryingCallerFactory(Configuration conf)
public RpcRetryingCallerFactory(Configuration conf, org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor)
public void setStatisticTracker(ServerStatisticTracker statisticTracker)
public <T> RpcRetryingCaller<T> newCaller(int rpcTimeout)
public <T> RpcRetryingCaller<T> newCaller()
public static RpcRetryingCallerFactory instantiate(Configuration configuration)
public static RpcRetryingCallerFactory instantiate(Configuration configuration, ServerStatisticTracker stats)
public static RpcRetryingCallerFactory instantiate(Configuration configuration, org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor, ServerStatisticTracker stats)