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

• pause

  private final long pause

• 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)