Uses of Class
org.apache.flink.api.common.time.Deadline

Packages that use Deadline

Package	Description
org.apache.flink.api.common.time
org.apache.flink.runtime.concurrent

Uses of Deadline in org.apache.flink.api.common.time

Methods in org.apache.flink.api.common.time that return Deadline

Modifier and Type	Method and Description
static Deadline	Deadline.fromNow(java.time.Duration duration) Constructs a Deadline that is a given duration after now.
static Deadline	Deadline.now() Constructs a Deadline that has now as the deadline.
Deadline	Deadline.plus(java.time.Duration other)

Uses of Deadline in org.apache.flink.runtime.concurrent

Methods in org.apache.flink.runtime.concurrent with parameters of type Deadline

Modifier and Type	Method and Description
static <T> CompletableFuture<T>	FutureUtils.retrySuccessfulWithDelay(java.util.function.Supplier<CompletableFuture<T>> operation, Time 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.