com.aliyun.odps.storage.internal.retry

Class RetryHandler

java.lang.Object

com.aliyun.odps.storage.internal.retry.RetryHandler

public class RetryHandler
extends Object

Retry handler for executing operations with automatic retry logic.

This handler provides retry capabilities based on HTTP status codes:

• 429 (Too Many Requests): infinite exponential retry with jitter
• 502, 503, 504, 500: limited exponential retry (7 times) with jitter
• 408 (Request Timeout): limited exponential retry (7 times) with jitter
• Other 4xx: no retry
• Other 5xx: limited exponential retry (7 times) with jitter

All retry strategies include jitter to prevent thundering herd problems when multiple clients retry simultaneously.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RetryHandler.RetryLogger Functional interface for logging retry attempts.

Constructor Summary

Constructors

Constructor and Description
RetryHandler()
RetryHandler(RetryHandler.RetryLogger retryLogger)
RetryHandler(RetryPolicy defaultRetryPolicy, RetryHandler.RetryLogger retryLogger)

Method Summary

Modifier and Type	Method and Description
<T> T	executeWithRetry(Callable<T> action) Executes an action with retry logic.
<T> T	executeWithRetry(Callable<T> action, IntConsumer errorCodeHandler) Executes an action with retry logic and error code handler.

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryHandler

public RetryHandler()

RetryHandler

public RetryHandler(RetryPolicy defaultRetryPolicy,
                    RetryHandler.RetryLogger retryLogger)

RetryHandler

public RetryHandler(RetryHandler.RetryLogger retryLogger)

Method Detail

executeWithRetry

public <T> T executeWithRetry(Callable<T> action)
                       throws Exception

Executes an action with retry logic.

Type Parameters:

T - The return type of the action

Parameters:

action - The action to execute

Returns:

The result of the action

Throws:

Exception - if the action fails after all retries

executeWithRetry

public <T> T executeWithRetry(Callable<T> action,
                              IntConsumer errorCodeHandler)
                       throws Exception

Executes an action with retry logic and error code handler.

Type Parameters:

T - The return type of the action

Parameters:

action - The action to execute

errorCodeHandler - Handler for error codes (called before each retry)

Returns:

The result of the action

Throws:

Exception - if the action fails after all retries