org.apache.lens.server.api.retry

Class ImmediateRetryHandler<FC extends FailureContext>

java.lang.Object

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

All Implemented Interfaces:

Serializable, BackOffRetryHandler<FC>

Direct Known Subclasses:

NoRetryHandler

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ImmediateRetryHandler()
ImmediateRetryHandler(int retries)

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

ImmediateRetryHandler

public ImmediateRetryHandler()

ImmediateRetryHandler

@ConstructorProperties(value="retries")
 @Generated(value="lombok")
public ImmediateRetryHandler(int retries)

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.