alluxio.retry

Class RetryUtils

java.lang.Object

alluxio.retry.RetryUtils

public final class RetryUtils
extends Object

Utilities for performing retries.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RetryUtils.RunnableThrowsIOException Interface for methods which return nothing and may throw IOException.

Method Summary

Modifier and Type	Method and Description
static RetryPolicy	defaultClientRetry() Gives a default ClientRetry based on config.
static RetryPolicy	defaultWorkerMasterClientRetry()
static void	retry(String action, RetryUtils.RunnableThrowsIOException f, RetryPolicy policy) Retries the given method until it doesn't throw an IO exception or the retry policy expires.
static <V> V	retryCallable(String description, Callable<V> f, RetryPolicy policy) Notice we assume the exception with the method is retryable, so we are not wasting time here.

Methods inherited from class java.lang.Object

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

Method Detail

retry

public static void retry(String action,
                         RetryUtils.RunnableThrowsIOException f,
                         RetryPolicy policy)
                  throws IOException

Retries the given method until it doesn't throw an IO exception or the retry policy expires. If the retry policy expires, the last exception generated will be rethrown. If no retry succeeds then a default IO Exception will be thrown.

Parameters:

action - a description of the action that fits the phrase "Failed to ${action}"

f - the function to retry

policy - the retry policy to use

Throws:

IOException

retryCallable

public static <V> V retryCallable(String description,
                                  Callable<V> f,
                                  RetryPolicy policy)

Notice we assume the exception with the method is retryable, so we are not wasting time here. Retries the given retryable method until it succeed or the retry policy expires. If the retry policy expires, the last exception generated will be rethrown as a AlluxioRuntimeException.

Type Parameters:

V - result type returned by callable

Parameters:

description - a description of the function

f - the function to retry which returns value

policy - the retry policy to use

Returns:

callable result

defaultClientRetry

public static RetryPolicy defaultClientRetry()

Gives a default ClientRetry based on config.

Returns:

default Client Retry policy based on config

defaultWorkerMasterClientRetry

public static RetryPolicy defaultWorkerMasterClientRetry()

Returns:

the default worker to master client retry