Package org.apache.flink.runtime.query
Class TaskKvStateRegistry
- java.lang.Object
-
- org.apache.flink.runtime.query.TaskKvStateRegistry
-
public class TaskKvStateRegistry extends Object
A helper for KvState registrations of a single task.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
registerKvState(KeyGroupRange keyGroupRange, String registrationName, InternalKvState<?,?,?> kvState, ClassLoader userClassLoader)
Registers the KvState instance at the KvStateRegistry.void
unregisterAll()
Unregisters all registered KvState instances from the KvStateRegistry.
-
-
-
Method Detail
-
registerKvState
public void registerKvState(KeyGroupRange keyGroupRange, String registrationName, InternalKvState<?,?,?> kvState, ClassLoader userClassLoader)
Registers the KvState instance at the KvStateRegistry.- Parameters:
keyGroupRange
- Key group range the KvState instance belongs toregistrationName
- The registration name (not necessarily the same as the KvState name defined in the state descriptor used to create the KvState instance)kvState
- The
-
unregisterAll
public void unregisterAll()
Unregisters all registered KvState instances from the KvStateRegistry.
-
-