org.apache.hadoop.io.retry

Class RetryInvocationHandler<T>

java.lang.Object

org.apache.hadoop.io.retry.RetryInvocationHandler<T>

All Implemented Interfaces:

Closeable, AutoCloseable, InvocationHandler, RpcInvocationHandler

Direct Known Subclasses:

LossyRetryInvocationHandler

@InterfaceAudience.Private
public class RetryInvocationHandler<T>
extends Object
implements RpcInvocationHandler

This class implements RpcInvocationHandler and supports retry on the client side.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider, RetryPolicy retryPolicy)
protected	RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider, RetryPolicy defaultPolicy, Map<String,RetryPolicy> methodNameToPolicyMap)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Client.ConnectionId	getConnectionId() Returns the connection id associated with the InvocationHandler instance.
Object	invoke(Object proxy, Method method, Object[] args)
protected Object	invokeMethod(Method method, Object[] args)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

RetryInvocationHandler

protected RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider,
                      RetryPolicy retryPolicy)

RetryInvocationHandler

protected RetryInvocationHandler(FailoverProxyProvider<T> proxyProvider,
                      RetryPolicy defaultPolicy,
                      Map<String,RetryPolicy> methodNameToPolicyMap)

Method Detail

invoke

public Object invoke(Object proxy,
            Method method,
            Object[] args)
              throws Throwable

Specified by:

invoke in interface InvocationHandler

Throws:

Throwable

invokeMethod

protected Object invokeMethod(Method method,
                  Object[] args)
                       throws Throwable

Throws:

Throwable

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getConnectionId

public Client.ConnectionId getConnectionId()

Description copied from interface: RpcInvocationHandler

Returns the connection id associated with the InvocationHandler instance.

Specified by:

getConnectionId in interface RpcInvocationHandler

Returns:

ConnectionId