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.util.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 Description static DeadlineDeadline. fromNow(java.time.Duration duration)Constructs a Deadline that is a given duration after now.static DeadlineDeadline. fromNowWithClock(java.time.Duration duration, Clock clock)Constructs a Deadline that is a given duration after now, where now and all other times from this deadline are defined by the givenClock.static DeadlineDeadline. now()Constructs aDeadlinethat has now as the deadline.DeadlineDeadline. plus(java.time.Duration other) -
Uses of Deadline in org.apache.flink.util.concurrent
Methods in org.apache.flink.util.concurrent with parameters of type Deadline 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.
-