org.apache.hadoop.hbase.client

Class RpcRetryingCaller<T>

java.lang.Object

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

Direct Known Subclasses:

StatsTrackingRpcRetryingCaller

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

Runs an rpc'ing RetryingCallable. Sets into rpc client threadlocal outstanding timeouts as so we don't persist too much. Dynamic rather than static so can set the generic appropriately. This object has a state. It should not be used by in parallel by different threads. Reusing it is possible however, even between multiple threads. However, the user will have to manage the synchronization on its side: there is no synchronization inside the class.

Field Summary

Fields

Modifier and Type	Field and Description
static Log	LOG

Constructor Summary

Constructors

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

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.
void	cancel()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Log LOG

Constructor Detail

RpcRetryingCaller

public RpcRetryingCaller(long pause,
                         int retries,
                         int startLogErrorsCnt)

RpcRetryingCaller

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

Method Detail

cancel

public void cancel()

callWithRetries

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

Retries if invocation fails.

Parameters:

callTimeout - Timeout for this call

callable - The RetryingCallable to run.

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

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

Returns:

an object of type T

Throws:

IOException - if a remote or network exception occurs

RuntimeException - other unspecified error

toString

public String toString()

Overrides:

toString in class Object