@InterfaceAudience.Private public class RpcRetryingCallerFactory extends Object
RpcRetryingCaller
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
static String |
CUSTOM_CALLER_CONF_KEY
Configuration key for a custom
RpcRetryingCaller |
Constructor and Description |
---|
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf) |
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor) |
Modifier and Type | Method and Description |
---|---|
static RpcRetryingCallerFactory |
instantiate(org.apache.hadoop.conf.Configuration configuration) |
static RpcRetryingCallerFactory |
instantiate(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor,
ServerStatisticTracker stats) |
static RpcRetryingCallerFactory |
instantiate(org.apache.hadoop.conf.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 String CUSTOM_CALLER_CONF_KEY
RpcRetryingCaller
protected final org.apache.hadoop.conf.Configuration conf
public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf)
public RpcRetryingCallerFactory(org.apache.hadoop.conf.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(org.apache.hadoop.conf.Configuration configuration)
public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration, ServerStatisticTracker stats)
public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor, ServerStatisticTracker stats)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.