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
static String	CUSTOM_CALLER_CONF_KEY Configuration key for a custom RpcRetryingCaller
private boolean	enableBackPressure
private RetryingCallerInterceptor	interceptor
private static org.slf4j.Logger	LOG
private long	pause
private long	pauseForCQTBE
private int	retries
private int	rpcTimeout
private int	startLogErrorsCnt
private ServerStatisticTracker	stats

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.
void	setStatisticTracker(ServerStatisticTracker statisticTracker) Set the tracker that should be used for tracking statistics about the server

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

LOG

private static final org.slf4j.Logger LOG

conf

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

pause

private final long pause

pauseForCQTBE

private final long pauseForCQTBE

retries

private final int retries

rpcTimeout

private final int rpcTimeout

interceptor

private final RetryingCallerInterceptor interceptor

startLogErrorsCnt

private final int startLogErrorsCnt

enableBackPressure

private final boolean enableBackPressure

stats

private ServerStatisticTracker stats

Constructor Detail

RpcRetryingCallerFactory

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

RpcRetryingCallerFactory

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

Method Detail

setStatisticTracker

public void setStatisticTracker(ServerStatisticTracker statisticTracker)

Set the tracker that should be used for tracking statistics about the server

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)