Package org.apache.beam.sdk.ml.inference.remote

Class RetryHandler

java.lang.Object

org.apache.beam.sdk.ml.inference.remote.RetryHandler

All Implemented Interfaces:

Serializable

public class RetryHandler
extends Object
implements Serializable

A utility for running request and handle failures and retries.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RetryHandler.RetryableRequest<T>
static interface	RetryHandler.RetryFilter

Method Summary

Modifier and Type	Method	Description
<T> T	execute(RetryHandler.RetryableRequest<T> request)
static RetryHandler	withDefaults()
RetryHandler	withRetryFilter(RetryHandler.RetryFilter retryFilter)

Methods inherited from class java.lang.Object

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

Method Details

withDefaults

public static RetryHandler withDefaults()

withRetryFilter

public RetryHandler withRetryFilter(RetryHandler.RetryFilter retryFilter)

execute

public <T> T execute(RetryHandler.RetryableRequest<T> request)
              throws Exception

Throws:

Exception