Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.kubernetes.utils |
Class and Description |
---|
KubernetesCheckpointStoreUtil
Singleton
CheckpointStoreUtil implementation for Kubernetes. |
KubernetesJobGraphStoreUtil
Singleton
JobGraphStoreUtil implementation for Kubernetes. |
KubernetesLeaderElectionDriver
LeaderElectionDriver implementation for Kubernetes. |
KubernetesLeaderRetrievalDriver
The counterpart to the
KubernetesLeaderElectionDriver . |
Class and Description |
---|
KubernetesStateHandleStore
Class which stores state via the provided
RetrievableStateStorageHelper and writes the
returned state handle to ConfigMap. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.