com.google.cloud.hadoop.util

Class ResilientOperation

java.lang.Object

com.google.cloud.hadoop.util.ResilientOperation

public class ResilientOperation
extends Object

A class which defines static functions to be called to make a user-provided function more resilient by attempting retries.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ResilientOperation.CheckedCallable<T,X extends Exception> Interface that allows a call that can throw an exception X.

Constructor Summary

Constructors

Constructor and Description
ResilientOperation()

Method Summary

Modifier and Type	Method and Description
static <V> ResilientOperation.CheckedCallable<V,IOException>	getGoogleRequestCallable(com.google.api.client.googleapis.services.AbstractGoogleClientRequest<V> request) Returns a ResilientOperation.CheckedCallable that returns encompasses a AbstractGoogleClientRequest and can be used to retry the execute for a AbstractGoogleClientReqest.
static <T,X extends Exception> T	retry(ResilientOperation.CheckedCallable<T,X> callable, com.google.api.client.util.BackOff backoff, RetryDeterminer<? super X> retryDet, Class<X> classType) Retries the given executable function in the case of transient errors defined by the RetryDeterminer and uses default sleeper.
static <T,X extends Exception> T	retry(ResilientOperation.CheckedCallable<T,X> callable, com.google.api.client.util.BackOff backoff, RetryDeterminer<? super X> retryDet, Class<X> classType, com.google.api.client.util.Sleeper sleeper) Retries the given executable function in the case of transient errors defined by the RetryDeterminer.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResilientOperation

public ResilientOperation()

Method Detail

retry

public static <T,X extends Exception> T retry(ResilientOperation.CheckedCallable<T,X> callable,
                                              com.google.api.client.util.BackOff backoff,
                                              RetryDeterminer<? super X> retryDet,
                                              Class<X> classType,
                                              com.google.api.client.util.Sleeper sleeper)
                                       throws X extends Exception,
                                              InterruptedException

Retries the given executable function in the case of transient errors defined by the RetryDeterminer.

Does not support unchecked exceptions that are not instances of RuntimeException.

Type Parameters:

T - Type of object returned by the call.

X - Type of exception thrown by the call.

Parameters:

callable - CheckedCallable to retry execution of

backoff - BackOff to determine how long to sleep for

retryDet - RetryDeterminer to determine when to retry

classType - class type of X

sleeper - Used to sleep

Throws:

X - What is thrown from the executable or the RetryDeterminer

InterruptedException - - Exception thrown from sleep

X extends Exception

retry

public static <T,X extends Exception> T retry(ResilientOperation.CheckedCallable<T,X> callable,
                                              com.google.api.client.util.BackOff backoff,
                                              RetryDeterminer<? super X> retryDet,
                                              Class<X> classType)
                                       throws X extends Exception,
                                              InterruptedException

Retries the given executable function in the case of transient errors defined by the RetryDeterminer and uses default sleeper.

Type Parameters:

T - Type of object returned by the call.

X - Type of exception thrown by the call.

Parameters:

callable - CheckedCallable to retry execution of

backoff - BackOff to determine how long to sleep for

retryDet - RetryDeterminer to determine when to retry

classType - class type of X

Throws:

X - What is thrown from the executable or the RetryDeterminer

InterruptedException - - Exception thrown from sleep

X extends Exception

getGoogleRequestCallable

public static <V> ResilientOperation.CheckedCallable<V,IOException> getGoogleRequestCallable(com.google.api.client.googleapis.services.AbstractGoogleClientRequest<V> request)

Returns a ResilientOperation.CheckedCallable that returns encompasses a AbstractGoogleClientRequest and can be used to retry the execute for a AbstractGoogleClientReqest.

Parameters:

request - The AbstractGoogleClientRequest to turn into a ResilientOperation.CheckedCallable.

Returns:

a CheckedCallable object that attempts a AbstractGoogleClientRequest