Package org.apache.flink.runtime.query

Interface Summary

Interface	Description
KvStateClientProxy	An interface for the Queryable State Client Proxy running on each Task Manager in the cluster.
KvStateMessage	Actor messages for InternalKvState lookup and registration.
KvStateRegistryGateway	A gateway to listen for KvState registrations.
KvStateRegistryListener	A listener for a KvStateRegistry.
KvStateServer	An interface for the Queryable State Server running on each Task Manager in the cluster.

Class Summary

Class	Description
KvStateLocation	Location information for all key groups of a InternalKvState instance.
KvStateLocationRegistry	Simple registry, which maps InternalKvState registration notifications to KvStateLocation instances.
KvStateMessage.LookupKvStateLocation	Actor message for looking up KvStateLocation.
KvStateMessage.NotifyKvStateRegistered	Actor message for notification of KvState registration.
KvStateMessage.NotifyKvStateUnregistered	Actor message for notification of KvState unregistration.
KvStateRegistry	A registry for InternalKvState instances per task manager.
QueryableStateUtils	Utility class to initialize entities used in queryable state.
TaskKvStateRegistry	A helper for KvState registrations of a single task.

Exception Summary

Exception	Description
UnknownKvStateLocation	Thrown if there is no KvStateLocation found for the requested registration name.