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

Constructor Summary

Constructors

Constructor and Description
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf)
RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.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, 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

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

Constructor Detail

RpcRetryingCallerFactory

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

RpcRetryingCallerFactory

public RpcRetryingCallerFactory(org.apache.hadoop.conf.Configuration conf,
                                org.apache.hadoop.hbase.client.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,
                                                   org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor,
                                                   ServerStatisticTracker stats)