Uses of Interface
org.apache.flink.runtime.state.KeyedStateFunction

Packages that use KeyedStateFunction

Package	Description
org.apache.flink.runtime.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.

Uses of KeyedStateFunction in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type KeyedStateFunction

Modifier and Type	Method	Description
<N,S extends org.apache.flink.api.common.state.State,T> void	AbstractKeyedStateBackend.applyToAllKeys(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor, KeyedStateFunction<K,S> function)
<N,S extends org.apache.flink.api.common.state.State,T> void	AbstractKeyedStateBackend.applyToAllKeys(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor, KeyedStateFunction<K,S> function, AbstractKeyedStateBackend.PartitionStateFactory partitionStateFactory)
<N,S extends org.apache.flink.api.common.state.State,T> void	KeyedStateBackend.applyToAllKeys(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor, KeyedStateFunction<K,S> function)	Applies the provided KeyedStateFunction to the state with the provided StateDescriptor of all the currently active keys.

Uses of KeyedStateFunction in org.apache.flink.runtime.state.heap

Methods in org.apache.flink.runtime.state.heap with parameters of type KeyedStateFunction

Modifier and Type	Method	Description
<N,S extends org.apache.flink.api.common.state.State,T> void	HeapKeyedStateBackend.applyToAllKeys(N namespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.api.common.state.StateDescriptor<S,T> stateDescriptor, KeyedStateFunction<K,S> function, AbstractKeyedStateBackend.PartitionStateFactory partitionStateFactory)