org.apache.hadoop.io.retry
Class RetryProxy

java.lang.Object
  org.apache.hadoop.io.retry.RetryProxy

public class RetryProxy
extends Object

A factory for creating retry proxies.

Constructor Summary

RetryProxy()

Method Summary

static Object	create(Class<?> iface, Object implementation, Map<String,RetryPolicy> methodNameToPolicyMap) Create a proxy for an interface of an implementation class using the a set of retry policies specified by method name.
static Object	create(Class<?> iface, Object implementation, RetryPolicy retryPolicy) Create a proxy for an interface of an implementation class using the same retry policy for each method in the interface.
static Object	create(Class<?> iface, Object implementation, RetryPolicy defaultPolicy, Map<String,RetryPolicy> methodNameToPolicyMap)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryProxy

public RetryProxy()

Method Detail

create

public static Object create(Class<?> iface,
                            Object implementation,
                            RetryPolicy retryPolicy)

Create a proxy for an interface of an implementation class using the same retry policy for each method in the interface.

Parameters:

iface - the interface that the retry will implement

implementation - the instance whose methods should be retried

retryPolicy - the policy for retirying method call failures

Returns:

the retry proxy

create

public static Object create(Class<?> iface,
                            Object implementation,
                            Map<String,RetryPolicy> methodNameToPolicyMap)

Create a proxy for an interface of an implementation class using the a set of retry policies specified by method name. If no retry policy is defined for a method then a default of RetryPolicies.TRY_ONCE_THEN_FAIL is used.

Parameters:

iface - the interface that the retry will implement

implementation - the instance whose methods should be retried

methodNameToPolicyMap - a map of method names to retry policies

Returns:

the retry proxy

create

public static Object create(Class<?> iface,
                            Object implementation,
                            RetryPolicy defaultPolicy,
                            Map<String,RetryPolicy> methodNameToPolicyMap)