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

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

registerKvState

public void registerKvState(KeyGroupRange keyGroupRange,
                            String registrationName,
                            InternalKvState<?,?,?> kvState)

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.