com.aliyun.odps.storage.internal.retry

Class ExponentialBackoffPolicy

java.lang.Object

com.aliyun.odps.storage.internal.retry.ExponentialBackoffPolicy

All Implemented Interfaces:

RetryPolicy

public class ExponentialBackoffPolicy
extends Object
implements RetryPolicy

A retry policy with exponential backoff and jitter.

This policy retries up to a maximum number of times with exponential backoff, and adds random jitter to prevent thundering herd problems when multiple clients retry simultaneously.

Wait time calculation: base_wait = 2^(attempt-1) seconds With jitter: final_wait = base_wait + (base_wait * 0.1 * random) Max wait time: 64 seconds

Field Summary

Fields

Modifier and Type	Field and Description
static ExponentialBackoffPolicy	INSTANCE

Method Summary

Modifier and Type	Method and Description
long	getRetryWaitTime(int attempt) Calculates the wait time before the next retry attempt.
boolean	shouldRetry(Exception e, int attempt) Determines whether an operation should be retried based on the exception and attempt count.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aliyun.odps.storage.internal.retry.RetryPolicy

waitForNextRetry

Field Detail

INSTANCE

public static final ExponentialBackoffPolicy INSTANCE

Method Detail

shouldRetry

public boolean shouldRetry(Exception e,
                           int attempt)

Description copied from interface: RetryPolicy

Determines whether an operation should be retried based on the exception and attempt count.

Specified by:

shouldRetry in interface RetryPolicy

Parameters:

e - The exception that occurred

attempt - The current attempt number (1-based)

Returns:

true if the operation should be retried, false otherwise

getRetryWaitTime

public long getRetryWaitTime(int attempt)

Description copied from interface: RetryPolicy

Calculates the wait time before the next retry attempt.

Specified by:

getRetryWaitTime in interface RetryPolicy

Parameters:

attempt - The current attempt number (1-based)

Returns:

The wait time in milliseconds