Package | Description |
---|---|
org.apache.flink.runtime.concurrent | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.util | |
org.apache.flink.util.function |
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<T> |
FutureUtils.supplyAsync(SupplierWithException<T,?> supplier,
Executor executor)
Returns a future which is completed with the result of the
SupplierWithException . |
Constructor and Description |
---|
BackendRestorerProcedure(SupplierWithException<T,Exception> instanceSupplier,
CloseableRegistry backendCloseableRegistry,
String logDescription)
Creates a new backend restorer using the given backend supplier and the closeable registry.
|
Modifier and Type | Method and Description |
---|---|
static <R,E extends Throwable> |
LambdaUtil.withContextClassLoader(ClassLoader cl,
SupplierWithException<R,E> s)
Runs the given runnable with the given ClassLoader as the thread's
context class loader . |
Modifier and Type | Interface and Description |
---|---|
interface |
CheckedSupplier<R>
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.