Package org.apache.flink.kubernetes.highavailability
-
Class Summary Class Description KubernetesCheckpointIDCounter CheckpointIDCounter
implementation for Kubernetes.KubernetesCheckpointRecoveryFactory Factory to createCompletedCheckpointStore
andCheckpointIDCounter
.KubernetesHaServicesFactory Factory for creating Kubernetes high availability services.KubernetesLeaderElectionDriver LeaderElectionDriver
for Kubernetes.KubernetesLeaderElectionDriverFactory Factory that instantiates aKubernetesLeaderElectionDriver
.KubernetesLeaderElectionHaServices Kubernetes HA services that use a single leader election service per JobManager.KubernetesLeaderRetrievalDriver The counterpart to theKubernetesLeaderElectionDriver
.KubernetesLeaderRetrievalDriverFactory Factory that instantiates aKubernetesLeaderRetrievalDriver
in single leader election mode.KubernetesStateHandleStore<T extends Serializable> Class which stores state via the providedRetrievableStateStorageHelper
and writes the returned state handle to ConfigMap. -
Enum Summary Enum Description KubernetesCheckpointStoreUtil SingletonCheckpointStoreUtil
implementation for Kubernetes.KubernetesJobGraphStoreUtil SingletonJobGraphStoreUtil
implementation for Kubernetes.