Uses of Interface
org.apache.flink.core.asyncprocessing.AsyncFuture

Packages that use AsyncFuture

Package	Description
org.apache.flink.core.asyncprocessing

Uses of AsyncFuture in org.apache.flink.core.asyncprocessing

Subinterfaces of AsyncFuture in org.apache.flink.core.asyncprocessing

Modifier and Type	Interface	Description
interface	InternalAsyncFuture<T>	The Internal definition of AsyncFuture, add some method that will be used by framework.

Classes in org.apache.flink.core.asyncprocessing that implement AsyncFuture

Modifier and Type	Class	Description
class	AsyncFutureImpl<T>	The default implementation of AsyncFuture.
class	CompletedAsyncFuture<T>	A AsyncFuture that has already been completed when it is created.

Methods in org.apache.flink.core.asyncprocessing that return AsyncFuture

Modifier and Type	Method	Description
AsyncFuture<Void>	AsyncFuture.thenAccept(org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> action)	Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied action.
<U> AsyncFuture<U>	AsyncFuture.thenApply(org.apache.flink.util.function.FunctionWithException<? super T,? extends U,? extends Exception> fn)	Returns a new StateFuture that, when this future completes normally, is executed with this future's result as the argument to the supplied function.
<U,V> AsyncFuture<V>	AsyncFuture.thenCombine(org.apache.flink.api.common.state.v2.StateFuture<? extends U> other, org.apache.flink.util.function.BiFunctionWithException<? super T,? super U,? extends V,? extends Exception> fn)	Returns a new StateFuture that, when this and the other given future both complete normally, is executed with the two results as arguments to the supplied function.
<U> AsyncFuture<U>	AsyncFuture.thenCompose(org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<U>,? extends Exception> action)	Returns a new future that, when this future completes normally, is executed with this future as the argument to the supplied function.
AsyncFuture<Boolean>	AsyncFuture.thenConditionallyAccept(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> actionIfTrue)	Apply a condition test on the result of this StateFuture, and try to perform the action if test result is true.
AsyncFuture<Boolean>	AsyncFuture.thenConditionallyAccept(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> actionIfTrue, org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> actionIfFalse)	Apply a condition test on the result of this StateFuture, and try to perform one action out of two based on the result.
<U> AsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	AsyncFuture.thenConditionallyApply(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.FunctionWithException<? super T,? extends U,? extends Exception> actionIfTrue)	Apply a condition test on the result of this StateFuture, and try to perform the action if test result is true.
<U,V> AsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	AsyncFuture.thenConditionallyApply(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.FunctionWithException<? super T,? extends U,? extends Exception> actionIfTrue, org.apache.flink.util.function.FunctionWithException<? super T,? extends V,? extends Exception> actionIfFalse)	Apply a condition test on the result of this StateFuture, and try to perform one action out of two based on the result.
<U> AsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	AsyncFuture.thenConditionallyCompose(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<U>,? extends Exception> actionIfTrue)	Apply a condition test on the result of this StateFuture, and try to perform the action if test result is true.
<U,V> AsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	AsyncFuture.thenConditionallyCompose(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<U>,? extends Exception> actionIfTrue, org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<V>,? extends Exception> actionIfFalse)	Apply a condition test on the result of this StateFuture, and try to perform one action out of two based on the result.