public class TaskKvStateRegistry extends Object
Modifier and Type | Method and Description |
---|---|
void |
registerKvState(KeyGroupRange keyGroupRange,
String registrationName,
InternalKvState<?,?,?> kvState)
Registers the KvState instance at the KvStateRegistry.
|
void |
unregisterAll()
Unregisters all registered KvState instances from the KvStateRegistry.
|
public void registerKvState(KeyGroupRange keyGroupRange, String registrationName, InternalKvState<?,?,?> kvState)
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
- Thepublic void unregisterAll()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.