Uses of Interface
org.apache.flink.util.function.RunnableWithException
-
Packages that use RunnableWithException Package Description org.apache.flink.api.common.operators org.apache.flink.util org.apache.flink.util.concurrent org.apache.flink.util.function -
-
Uses of RunnableWithException in org.apache.flink.api.common.operators
Methods in org.apache.flink.api.common.operators with parameters of type RunnableWithException Modifier and Type Method Description default Future<Void>MailboxExecutor. submit(RunnableWithException command, String description)Submits the given command for execution in the future in the mailbox thread and returns a Future representing that command.default Future<Void>MailboxExecutor. submit(RunnableWithException command, String descriptionFormat, Object... descriptionArgs)Submits the given command for execution in the future in the mailbox thread and returns a Future representing that command. -
Uses of RunnableWithException in org.apache.flink.util
Methods in org.apache.flink.util with parameters of type RunnableWithException Modifier and Type Method Description static voidExceptionUtils. suppressExceptions(RunnableWithException action) -
Uses of RunnableWithException in org.apache.flink.util.concurrent
Methods in org.apache.flink.util.concurrent with parameters of type RunnableWithException Modifier and Type Method Description static CompletableFuture<Void>FutureUtils. runAfterwards(CompletableFuture<?> future, RunnableWithException runnable)Run the given action after the completion of the given future.static CompletableFuture<Void>FutureUtils. runAfterwardsAsync(CompletableFuture<?> future, RunnableWithException runnable)Run the given action after the completion of the given future.static CompletableFuture<Void>FutureUtils. runAfterwardsAsync(CompletableFuture<?> future, RunnableWithException runnable, Executor executor)Run the given action after the completion of the given future. -
Uses of RunnableWithException in org.apache.flink.util.function
Classes in org.apache.flink.util.function that implement RunnableWithException Modifier and Type Class Description classFutureTaskWithException<V>FutureTaskthat also implementsRunnableWithException.Methods in org.apache.flink.util.function with parameters of type RunnableWithException Modifier and Type Method Description static <T> Callable<T>FunctionUtils. asCallable(RunnableWithException command, T result)Constructors in org.apache.flink.util.function with parameters of type RunnableWithException Constructor Description FutureTaskWithException(RunnableWithException command)
-