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

Packages that use ScheduledExecutor

Package	Description
org.apache.flink.util.concurrent

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

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

Modifier and Type	Class	Description
class	ScheduledExecutorServiceAdapter	Adapter class for a ScheduledExecutorService which shall be used as a ScheduledExecutor.

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

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureUtils.retrySuccessfulWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, java.time.Duration retryDelay, Deadline deadline, java.util.function.Predicate<T> acceptancePredicate, ScheduledExecutor scheduledExecutor)	Retry the given operation with the given delay in between successful completions where the result does not match a given predicate.
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.