org.apache.hadoop.hbase.client

Class RpcRetryingCallerFactory

java.lang.Object

org.apache.hadoop.hbase.client.RpcRetryingCallerFactory

@InterfaceAudience.Private
public class RpcRetryingCallerFactory
extends Object

Factory to create an RpcRetryingCaller

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	conf
private ConnectionConfiguration	connectionConf
static String	CUSTOM_CALLER_CONF_KEY Configuration key for a custom RpcRetryingCaller
private RetryingCallerInterceptor	interceptor
private int	startLogErrorsCnt

Constructor Summary

Constructors

Constructor and Description
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf)
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf, RetryingCallerInterceptor interceptor)

Method Summary

Modifier and Type	Method and Description
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration)
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration, 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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CUSTOM_CALLER_CONF_KEY

public static final String CUSTOM_CALLER_CONF_KEY

Configuration key for a custom RpcRetryingCaller

See Also:

Constant Field Values

conf

protected final org.apache.hadoop.conf.Configuration conf

connectionConf

private final ConnectionConfiguration connectionConf

interceptor

private final RetryingCallerInterceptor interceptor

startLogErrorsCnt

private final int startLogErrorsCnt

Constructor Detail

RpcRetryingCallerFactory

public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf)

RpcRetryingCallerFactory

public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf,
                                RetryingCallerInterceptor interceptor)

Method Detail

newCaller

public <T> RpcRetryingCaller<T> newCaller(int rpcTimeout)

Create a new RetryingCaller with specific rpc timeout.

newCaller

public <T> RpcRetryingCaller<T> newCaller()

Create a new RetryingCaller with configured rpc timeout.

instantiate

public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration)

instantiate

public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration,
                                                   ServerStatisticTracker stats)

instantiate

public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration,
                                                   RetryingCallerInterceptor interceptor,
                                                   ServerStatisticTracker stats)