Package | Description |
---|---|
org.apache.flink.runtime.concurrent | |
org.apache.flink.runtime.concurrent.impl |
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
Future.handle(BiFunction<? super T,Throwable,? extends R> biFunction)
Applies the given handle function to the result of the future.
|
<R> Future<R> |
Future.handleAsync(BiFunction<? super T,Throwable,? extends R> biFunction,
Executor executor)
Applies the given handle function to the result of the future.
|
<U,R> Future<R> |
Future.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction)
Applies the given function to the result of this and the other future after both futures
have completed.
|
<U,R> Future<R> |
Future.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor)
Applies the given function to the result of this and the other future after both futures
have completed.
|
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
FlinkFuture.handle(BiFunction<? super T,Throwable,? extends R> biFunction) |
<R> Future<R> |
FlinkFuture.handleAsync(BiFunction<? super T,Throwable,? extends R> biFunction,
Executor executor) |
<U,R> Future<R> |
FlinkFuture.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction) |
<U,R> Future<R> |
FlinkFuture.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.