Package org.apache.hadoop.io.retry

Class LossyRetryInvocationHandler<T>

java.lang.Object

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, InvocationHandler, RpcInvocationHandler

@Private
public class LossyRetryInvocationHandler<T>
extends RetryInvocationHandler<T>

A dummy invocation handler extending RetryInvocationHandler. It drops the first N number of responses. This invocation handler is only used for testing.

Field Summary

Fields inherited from class org.apache.hadoop.io.retry.RetryInvocationHandler

LOG, SET_CALL_ID_FOR_TEST

Constructor Summary

Constructors

Constructor	Description
LossyRetryInvocationHandler(int numToDrop, FailoverProxyProvider<T> proxyProvider, RetryPolicy retryPolicy)

Method Summary

Modifier and Type	Method	Description
Object	invoke(Object proxy, Method method, Object[] args)
protected Object	invokeMethod(Method method, Object[] args)

Methods inherited from class org.apache.hadoop.io.retry.RetryInvocationHandler

close, getConnectionId, getProxyProvider

Methods inherited from class java.lang.Object

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

Constructor Details

LossyRetryInvocationHandler

public LossyRetryInvocationHandler(int numToDrop,
 FailoverProxyProvider<T> proxyProvider,
 RetryPolicy retryPolicy)

Method Details

invoke

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

Specified by:

invoke in interface InvocationHandler

Overrides:

invoke in class RetryInvocationHandler<T>

Throws:

Throwable

invokeMethod

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

Overrides:

invokeMethod in class RetryInvocationHandler<T>

Throws:

Throwable