Package | Description |
---|---|
org.apache.flink.runtime.concurrent | |
org.apache.flink.runtime.concurrent.impl |
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
Future.exceptionally(ApplyFunction<Throwable,? extends R> exceptionallyFunction)
Applies the given function to the value of the future if the future has been completed
exceptionally.
|
<R> Future<R> |
Future.exceptionallyAsync(ApplyFunction<Throwable,? extends R> exceptionallyFunction,
Executor executor)
Applies the given function to the value of the future if the future has been completed
exceptionally.
|
<R> Future<R> |
Future.thenApply(ApplyFunction<? super T,? extends R> applyFunction)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenApplyAsync(ApplyFunction<? super T,? extends R> applyFunction,
Executor executor)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> composeFunction,
Executor executor)
Applies the given function to the value of the future.
|
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
FlinkFuture.exceptionally(ApplyFunction<Throwable,? extends R> exceptionallyFunction) |
<R> Future<R> |
FlinkFuture.exceptionallyAsync(ApplyFunction<Throwable,? extends R> exceptionallyFunction,
Executor executor) |
<R> Future<R> |
FlinkFuture.thenApply(ApplyFunction<? super T,? extends R> applyFunction) |
<R> Future<R> |
FlinkFuture.thenApplyAsync(ApplyFunction<? super T,? extends R> applyFunction,
Executor executor) |
<R> Future<R> |
FlinkFuture.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction) |
<R> Future<R> |
FlinkFuture.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> applyFunction,
Executor executor) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.