org.apache.hadoop.hbase.client

Class RpcRetryingCallerImpl<T>

java.lang.Object

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

All Implemented Interfaces:

RpcRetryingCaller<T>

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

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 org.slf4j.Logger	LOG

Constructor Summary

Constructors

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

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 org.slf4j.Logger LOG

Constructor Detail

RpcRetryingCallerImpl

public RpcRetryingCallerImpl(long pause,
                             long pauseForCQTBE,
                             int retries,
                             int startLogErrorsCnt)

RpcRetryingCallerImpl

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

Method Detail

cancel

public void cancel()

Specified by:

cancel in interface RpcRetryingCaller<T>

callWithRetries

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

Description copied from interface: RpcRetryingCaller

Retries if invocation fails.

Specified by:

callWithRetries in interface 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 interface: RpcRetryingCaller

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

Specified by:

callWithoutRetries in interface RpcRetryingCaller<T>

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