org.apache.lens.server.api.retry

Class FibonacciExponentialBackOffRetryHandler<FC extends FailureContext>

java.lang.Object

org.apache.lens.server.api.retry.FibonacciExponentialBackOffRetryHandler<FC>

All Implemented Interfaces:

Serializable, BackOffRetryHandler<FC>

public class FibonacciExponentialBackOffRetryHandler<FC extends FailureContext>
extends Object
implements BackOffRetryHandler<FC>

A exponential backoff retry handler. It allows the the failures to be retried at a next update time, which can increase exponentially.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FibonacciExponentialBackOffRetryHandler(int numRetries, long maxDelay, long waitMillis)

Method Summary

Modifier and Type	Method and Description
boolean	canTryOpNow(FC failContext) To know whether operation can be done now.
long	getOperationNextTime(FC failContext) Get the time when the operation can be done next.
boolean	hasExhaustedRetries(FC failContext) Has the operation exhausted all its retries

Methods inherited from class java.lang.Object

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

Constructor Detail

FibonacciExponentialBackOffRetryHandler

public FibonacciExponentialBackOffRetryHandler(int numRetries,
                                               long maxDelay,
                                               long waitMillis)

Method Detail

canTryOpNow

public boolean canTryOpNow(FC failContext)

Description copied from interface: BackOffRetryHandler

To know whether operation can be done now.

Specified by:

canTryOpNow in interface BackOffRetryHandler<FC extends FailureContext>

Parameters:

failContext - FailureContext holding failures till now.

Returns:

true if operation can be done now, false otherwise.

getOperationNextTime

public long getOperationNextTime(FC failContext)

Description copied from interface: BackOffRetryHandler

Get the time when the operation can be done next.

Specified by:

getOperationNextTime in interface BackOffRetryHandler<FC extends FailureContext>

Parameters:

failContext - FC holding failures till now.

Returns:

Next operation time in millis since epoch

hasExhaustedRetries

public boolean hasExhaustedRetries(FC failContext)

Description copied from interface: BackOffRetryHandler

Has the operation exhausted all its retries

Specified by:

hasExhaustedRetries in interface BackOffRetryHandler<FC extends FailureContext>

Parameters:

failContext - FC holding failures till now.

Returns:

true if all retries have exhausted, false otherwise.