程序包 org.apache.hadoop.io.retry

A mechanism for selectively retrying methods that throw exceptions under certain circumstances.

请参阅: 说明

接口概要

接口	说明
RetryPolicy	Specifies a policy for retrying method failures.

类概要

类	说明
RetryPolicies	A collection of useful implementations of RetryPolicy.
RetryPolicies.MultipleLinearRandomRetry	Given pairs of number of retries and sleep time (n0, t0), (n1, t1), ..., the first n0 retries sleep t0 milliseconds on average, the following n1 retries sleep t1 milliseconds on average, and so on.
RetryPolicies.MultipleLinearRandomRetry.Pair	Pairs of numRetries and sleepSeconds
RetryProxy	A factory for creating retry proxies.
RetryUtils

程序包org.apache.hadoop.io.retry的说明

A mechanism for selectively retrying methods that throw exceptions under certain circumstances.

Typical usage is

UnreliableImplementation unreliableImpl = new UnreliableImplementation();
UnreliableInterface unreliable = (UnreliableInterface)
  RetryProxy.create(UnreliableInterface.class, unreliableImpl,
    RetryPolicies.retryUpToMaximumCountWithFixedSleep(4, 10, TimeUnit.SECONDS));
unreliable.call();

This will retry any method called on unreliable four times - in this case the call() method - sleeping 10 seconds between each retry. There are a number of retry policies available, or you can implement a custom one by implementing RetryPolicy. It is also possible to specify retry policies on a per-method basis.