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

@InterfaceAudience.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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

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

Constructor Detail

LossyRetryInvocationHandler

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

Method Detail

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