org.apache.hadoop.hbase.client

Class StatsTrackingRpcRetryingCaller<T>

java.lang.Object

org.apache.hadoop.hbase.client.RpcRetryingCaller<T>

org.apache.hadoop.hbase.client.StatsTrackingRpcRetryingCaller<T>

@InterfaceAudience.Private
public class StatsTrackingRpcRetryingCaller<T>
extends RpcRetryingCaller<T>

An RpcRetryingCaller that will update the per-region stats for the call on return, if stats are available

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.RpcRetryingCaller

LOG

Constructor Summary

Constructors

Constructor and Description
StatsTrackingRpcRetryingCaller(long pause, int retries, int startLogErrorsCnt, ServerStatisticTracker stats)
StatsTrackingRpcRetryingCaller(long pause, int retries, org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor, int startLogErrorsCnt, ServerStatisticTracker stats)

Method Summary

Modifier and Type	Method and Description
T	callWithoutRetries(RetryingCallable<T> callable, int callTimeout) Call the server once only.
T	callWithRetries(RetryingCallable<T> callable, int callTimeout) Retries if invocation fails.

Methods inherited from class org.apache.hadoop.hbase.client.RpcRetryingCaller

cancel, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

StatsTrackingRpcRetryingCaller

public StatsTrackingRpcRetryingCaller(long pause,
                                      int retries,
                                      int startLogErrorsCnt,
                                      ServerStatisticTracker stats)

StatsTrackingRpcRetryingCaller

public StatsTrackingRpcRetryingCaller(long pause,
                                      int retries,
                                      org.apache.hadoop.hbase.client.RetryingCallerInterceptor interceptor,
                                      int startLogErrorsCnt,
                                      ServerStatisticTracker stats)

Method Detail

callWithRetries

public T callWithRetries(RetryingCallable<T> callable,
                         int callTimeout)
                  throws IOException,
                         RuntimeException

Description copied from class: RpcRetryingCaller

Retries if invocation fails.

Overrides:

callWithRetries in class RpcRetryingCaller<T>

Parameters:

callable - The RetryingCallable to run.

callTimeout - Timeout for this call

Returns:

an object of type T

Throws:

IOException - if a remote or network exception occurs

RuntimeException - other unspecified error

callWithoutRetries

public T callWithoutRetries(RetryingCallable<T> callable,
                            int callTimeout)
                     throws IOException,
                            RuntimeException

Description copied from class: RpcRetryingCaller

Call the server once only. RetryingCallable has a strange shape so we can do retrys. Use this invocation if you want to do a single call only (A call to RetryingCallable.call(int) will not likely succeed).

Overrides:

callWithoutRetries in class RpcRetryingCaller<T>

Returns:

an object of type T

Throws:

IOException - if a remote or network exception occurs

RuntimeException - other unspecified error