Uses of Interface
org.apache.flink.util.function.FunctionWithException

Packages that use FunctionWithException

Package	Description
org.apache.flink.api.common.state.v2
org.apache.flink.util.function

Uses of FunctionWithException in org.apache.flink.api.common.state.v2

Methods in org.apache.flink.api.common.state.v2 with parameters of type FunctionWithException

Modifier and Type	Method	Description
<U> StateFuture<Collection<U>>	StateIterator.onNext(FunctionWithException<T,StateFuture<? extends U>,Exception> iterating)	Async iterate the data and call the callback when data is ready.
<U> StateFuture<U>	StateFuture.thenApply(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> StateFuture<U>	StateFuture.thenCompose(FunctionWithException<? super T,? extends 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.
StateFuture<Boolean>	StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition, 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.
StateFuture<Boolean>	StateFuture.thenConditionallyAccept(FunctionWithException<? super T,Boolean,? extends Exception> condition, ThrowingConsumer<? super T,? extends Exception> actionIfTrue, 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> StateFuture<Tuple2<Boolean,U>>	StateFuture.thenConditionallyApply(FunctionWithException<? super T,Boolean,? extends Exception> condition, 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> StateFuture<Tuple2<Boolean,Object>>	StateFuture.thenConditionallyApply(FunctionWithException<? super T,Boolean,? extends Exception> condition, FunctionWithException<? super T,? extends U,? extends Exception> actionIfTrue, 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> StateFuture<Tuple2<Boolean,U>>	StateFuture.thenConditionallyCompose(FunctionWithException<? super T,Boolean,? extends Exception> condition, FunctionWithException<? super T,? extends 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> StateFuture<Tuple2<Boolean,Object>>	StateFuture.thenConditionallyCompose(FunctionWithException<? super T,Boolean,? extends Exception> condition, FunctionWithException<? super T,? extends StateFuture<U>,? extends Exception> actionIfTrue, FunctionWithException<? super T,? extends 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.

Uses of FunctionWithException in org.apache.flink.util.function

Methods in org.apache.flink.util.function with parameters of type FunctionWithException

Modifier and Type	Method	Description
static <A,B> Function<A,B>	FunctionWithException.unchecked(FunctionWithException<A,B,?> functionWithException)	Convert at FunctionWithException into a Function.