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

Packages that use InternalAsyncFuture

Package	Description
org.apache.flink.core.asyncprocessing

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

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

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 InternalAsyncFuture

Modifier and Type	Method	Description
static <V> InternalAsyncFuture<V>	InternalAsyncFutureUtils.completedFuture(V result)	Returns a completed future that does nothing and return provided result.
static <V> InternalAsyncFuture<V>	InternalAsyncFutureUtils.completedVoidFuture()	Returns a completed future that does nothing and return null.
InternalAsyncFuture<Void>	AsyncFutureImpl.thenAccept(org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> action)
InternalAsyncFuture<Void>	CompletedAsyncFuture.thenAccept(org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> action)
InternalAsyncFuture<Void>	InternalAsyncFuture.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> InternalAsyncFuture<U>	AsyncFutureImpl.thenApply(org.apache.flink.util.function.FunctionWithException<? super T,? extends U,? extends Exception> fn)
<U> InternalAsyncFuture<U>	CompletedAsyncFuture.thenApply(org.apache.flink.util.function.FunctionWithException<? super T,? extends U,? extends Exception> fn)
<U> InternalAsyncFuture<U>	InternalAsyncFuture.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> InternalAsyncFuture<V>	AsyncFutureImpl.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)
<U,V> InternalAsyncFuture<V>	CompletedAsyncFuture.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)
<U,V> InternalAsyncFuture<V>	InternalAsyncFuture.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> InternalAsyncFuture<U>	AsyncFutureImpl.thenCompose(org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<U>,? extends Exception> action)
<U> InternalAsyncFuture<U>	CompletedAsyncFuture.thenCompose(org.apache.flink.util.function.FunctionWithException<? super T,? extends org.apache.flink.api.common.state.v2.StateFuture<U>,? extends Exception> action)
<U> InternalAsyncFuture<U>	InternalAsyncFuture.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.
InternalAsyncFuture<Boolean>	AsyncFutureImpl.thenConditionallyAccept(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> actionIfTrue)
InternalAsyncFuture<Boolean>	AsyncFutureImpl.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)
InternalAsyncFuture<Boolean>	CompletedAsyncFuture.thenConditionallyAccept(org.apache.flink.util.function.FunctionWithException<? super T,Boolean,? extends Exception> condition, org.apache.flink.util.function.ThrowingConsumer<? super T,? extends Exception> actionIfTrue)
InternalAsyncFuture<Boolean>	CompletedAsyncFuture.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)
InternalAsyncFuture<Boolean>	InternalAsyncFuture.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.
InternalAsyncFuture<Boolean>	InternalAsyncFuture.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> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	AsyncFutureImpl.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)
<U,V> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	AsyncFutureImpl.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)
<U> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	CompletedAsyncFuture.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)
<U,V> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	CompletedAsyncFuture.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)
<U> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	InternalAsyncFuture.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> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	InternalAsyncFuture.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> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	AsyncFutureImpl.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)
<U,V> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	AsyncFutureImpl.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)
<U> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	CompletedAsyncFuture.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)
<U,V> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	CompletedAsyncFuture.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)
<U> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,U>>	InternalAsyncFuture.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> InternalAsyncFuture<org.apache.flink.api.java.tuple.Tuple2<Boolean,Object>>	InternalAsyncFuture.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.