Uses of Interface
org.apache.flink.api.common.state.v2.StateFuture

Packages that use StateFuture

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

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

Methods in org.apache.flink.api.common.state.v2 that return StateFuture

Modifier and Type	Method	Description
StateFuture<Void>	AppendingState.asyncAdd(IN value)	Updates the operator state accessible by AppendingState.asyncGet() by adding the given value to the list of values.
StateFuture<Void>	ListState.asyncAddAll(List<T> values)	Updates the operator state accessible by AppendingState.asyncGet() by adding the given values to existing list of values.
StateFuture<Void>	State.asyncClear()	Removes the value mapped under the current key asynchronously.
StateFuture<Boolean>	MapState.asyncContains(UK key)	Returns whether there exists the given mapping asynchronously.
StateFuture<StateIterator<Map.Entry<UK,UV>>>	MapState.asyncEntries()	Returns the current iterator for all the mappings of this state asynchronously.
StateFuture<OUT>	AppendingState.asyncGet()	Returns the current value for the state.
StateFuture<UV>	MapState.asyncGet(UK key)	Returns the current value associated with the given key asynchronously.
StateFuture<Boolean>	MapState.asyncIsEmpty()	Returns whether this state contains no key-value mappings asynchronously.
StateFuture<StateIterator<UK>>	MapState.asyncKeys()	Returns the current iterator for all the keys of this state asynchronously.
StateFuture<Void>	MapState.asyncPut(UK key, UV value)	Update the current value associated with the given key asynchronously.
StateFuture<Void>	MapState.asyncPutAll(Map<UK,UV> map)	Update all of the mappings from the given map into the state asynchronously.
StateFuture<Void>	MapState.asyncRemove(UK key)	Delete the mapping of the given key from the state asynchronously.
StateFuture<Void>	ListState.asyncUpdate(List<T> values)	Updates the operator state accessible by AppendingState.asyncGet() by updating existing values to the given list of values.
StateFuture<Void>	ValueState.asyncUpdate(T value)	Updates the operator state accessible by ValueState.asyncValue() to the given value.
StateFuture<T>	ValueState.asyncValue()	Returns the current value for the state asynchronously.
StateFuture<StateIterator<UV>>	MapState.asyncValues()	Returns the current iterator for all the values of this state asynchronously.
StateFuture<Void>	StateIterator.onNext(java.util.function.Consumer<T> iterating)	Async iterate the data and call the callback when data is ready.
<U> StateFuture<Collection<U>>	StateIterator.onNext(java.util.function.Function<T,StateFuture<? extends U>> iterating)	Async iterate the data and call the callback when data is ready.
StateFuture<Void>	StateFuture.thenAccept(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> 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,V> StateFuture<V>	StateFuture.thenCombine(StateFuture<? extends U> other, 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> 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.

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

Modifier and Type	Method	Description
<U,V> StateFuture<V>	StateFuture.thenCombine(StateFuture<? extends U> other, 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.

Method parameters in org.apache.flink.api.common.state.v2 with type arguments of type StateFuture

Modifier and Type	Method	Description
<U> StateFuture<Collection<U>>	StateIterator.onNext(java.util.function.Function<T,StateFuture<? extends U>> iterating)	Async iterate the data and call the callback when data is ready.
<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.