org.apache.hadoop.io.retry

Interface RetryPolicy

All Known Implementing Classes:

RetryPolicies.MultipleLinearRandomRetry

@InterfaceStability.Evolving
public interface RetryPolicy

Specifies a policy for retrying method failures. Implementations of this interface should be immutable.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	RetryPolicy.RetryAction Returned by shouldRetry(Exception, int, int, boolean).

Method Summary

Methods

Modifier and Type	Method and Description
RetryPolicy.RetryAction	shouldRetry(Exception e, int retries, int failovers, boolean isIdempotentOrAtMostOnce) Determines whether the framework should retry a method for the given exception, and the number of retries that have been made for that operation so far.

Method Detail

shouldRetry

RetryPolicy.RetryAction shouldRetry(Exception e,
                                  int retries,
                                  int failovers,
                                  boolean isIdempotentOrAtMostOnce)
                                    throws Exception

Determines whether the framework should retry a method for the given exception, and the number of retries that have been made for that operation so far.

Parameters:

e - The exception that caused the method to fail

retries - The number of times the method has been retried

failovers - The number of times the method has failed over to a different backend implementation

isIdempotentOrAtMostOnce - true if the method is Idempotent or AtMostOnce and so can reasonably be retried on failover when we don't know if the previous attempt reached the server or not

Returns:

true if the method should be retried, false if the method should not be retried but shouldn't fail with an exception (only for void methods)

Throws:

Exception - The re-thrown exception e indicating that the method failed and should not be retried further