Package org.apache.hadoop.hbase.client

Class RpcRetryingCallerFactory

java.lang.Object

org.apache.hadoop.hbase.client.RpcRetryingCallerFactory

@Private
public class RpcRetryingCallerFactory
extends Object

Factory to create an RpcRetryingCaller

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionConfiguration	connectionConf
static final String	CUSTOM_CALLER_CONF_KEY	Configuration key for a custom RpcRetryingCaller
private final RetryingCallerInterceptor	interceptor
private final MetricsConnection	metrics
private final int	startLogErrorsCnt

Constructor Summary

Constructors

Constructor	Description
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf, ConnectionConfiguration connectionConf)
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf, ConnectionConfiguration connectionConf, RetryingCallerInterceptor interceptor, MetricsConnection metrics)

Method Summary

Modifier and Type	Method	Description
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration, ConnectionConfiguration connectionConf, MetricsConnection metrics)
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration, ConnectionConfiguration connectionConf, RetryingCallerInterceptor interceptor, ServerStatisticTracker stats, MetricsConnection metrics)
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration, ConnectionConfiguration connectionConf, ServerStatisticTracker stats, MetricsConnection metrics)
static RpcRetryingCallerFactory	instantiate(org.apache.hadoop.conf.Configuration configuration, MetricsConnection metrics)
<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 Details

CUSTOM_CALLER_CONF_KEY

public static final String CUSTOM_CALLER_CONF_KEY

Configuration key for a custom RpcRetryingCaller

See Also:

• Constant Field Values

connectionConf

private final ConnectionConfiguration connectionConf

interceptor

private final RetryingCallerInterceptor interceptor

startLogErrorsCnt

private final int startLogErrorsCnt

metrics

private final MetricsConnection metrics

Constructor Details

RpcRetryingCallerFactory

public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf,
 ConnectionConfiguration connectionConf)

RpcRetryingCallerFactory

public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf,
 ConnectionConfiguration connectionConf,
 RetryingCallerInterceptor interceptor,
 MetricsConnection metrics)

Method Details

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,
 MetricsConnection metrics)

instantiate

public static RpcRetryingCallerFactory instantiate(org.apache.hadoop.conf.Configuration configuration,
 ConnectionConfiguration connectionConf,
 MetricsConnection metrics)

instantiate

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

instantiate

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