Class TaskKvStateRegistry


  • public class TaskKvStateRegistry
    extends Object
    A helper for KvState registrations of a single task.
    • 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 to
        registrationName - 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.