Package org.apache.flink.kubernetes.highavailability

Class Summary

Class	Description
KubernetesCheckpointIDCounter	CheckpointIDCounter implementation for Kubernetes.
KubernetesCheckpointRecoveryFactory	Factory to create CompletedCheckpointStore and CheckpointIDCounter.
KubernetesHaServicesFactory	Factory for creating Kubernetes high availability services.
KubernetesLeaderElectionDriver	LeaderElectionDriver for Kubernetes.
KubernetesLeaderElectionDriverFactory	Factory that instantiates a KubernetesLeaderElectionDriver.
KubernetesLeaderElectionHaServices	Kubernetes HA services that use a single leader election service per JobManager.
KubernetesLeaderRetrievalDriver	The counterpart to the KubernetesLeaderElectionDriver.
KubernetesLeaderRetrievalDriverFactory	Factory that instantiates a KubernetesLeaderRetrievalDriver in single leader election mode.
KubernetesStateHandleStore<T extends Serializable>	Class which stores state via the provided RetrievableStateStorageHelper and writes the returned state handle to ConfigMap.

Enum Summary

Enum	Description
KubernetesCheckpointStoreUtil	Singleton CheckpointStoreUtil implementation for Kubernetes.
KubernetesJobGraphStoreUtil	Singleton JobGraphStoreUtil implementation for Kubernetes.