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(Duration duration)Constructs a Deadline that is a given duration after now.static DeadlineDeadline. fromNowWithClock(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(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(Supplier<CompletableFuture<T>> operation, Duration retryDelay, Deadline deadline, 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.
-