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.
|
org.apache.flink.streaming.api.functions.co |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
KeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
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. |
<N,S extends State,T> |
AbstractKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
HeapKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
Modifier and Type | Method and Description |
---|---|
abstract <VS,S extends State> |
KeyedBroadcastProcessFunction.Context.applyToKeyedState(StateDescriptor<S,VS> stateDescriptor,
KeyedStateFunction<KS,S> function)
Applies the provided
function to the state associated with the provided state descriptor . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.