Uses of Interface
org.apache.flink.util.concurrent.RetryStrategy

Packages that use RetryStrategy

Package	Description
org.apache.flink.util.concurrent

Uses of RetryStrategy in org.apache.flink.util.concurrent

Classes in org.apache.flink.util.concurrent that implement RetryStrategy

Modifier and Type	Class	Description
class	ExponentialBackoffRetryStrategy	An implementation of RetryStrategy that retries that has an exponential backoff with a cap.
class	FixedRetryStrategy	An implementation of RetryStrategy that retries at a fixed delay.
class	IncrementalDelayRetryStrategy	An implementation of RetryStrategy that retries at an incremental delay with a cap.

Methods in org.apache.flink.util.concurrent that return RetryStrategy

Modifier and Type	Method	Description
RetryStrategy	ExponentialBackoffRetryStrategy.getNextRetryStrategy()
RetryStrategy	FixedRetryStrategy.getNextRetryStrategy()
RetryStrategy	IncrementalDelayRetryStrategy.getNextRetryStrategy()
RetryStrategy	RetryStrategy.getNextRetryStrategy()

Methods in org.apache.flink.util.concurrent with parameters of type RetryStrategy

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, RetryStrategy retryStrategy, java.util.function.Predicate<Throwable> retryPredicate, ScheduledExecutor scheduledExecutor)	Retry the given operation with the given delay in between failures.
static <T> CompletableFuture<T>	FutureUtils.retryWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, RetryStrategy retryStrategy, ScheduledExecutor scheduledExecutor)	Retry the given operation with the given delay in between failures.