Package | Description |
---|---|
org.apache.flink.runtime.concurrent | |
org.apache.flink.util |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
static void |
ExceptionUtils.suppressExceptions(RunnableWithException action) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.