Uses of Class
org.apache.flink.kubernetes.configuration.KubernetesLeaderElectionConfiguration
-
-
Uses of KubernetesLeaderElectionConfiguration in org.apache.flink.kubernetes.highavailability
Constructors in org.apache.flink.kubernetes.highavailability with parameters of type KubernetesLeaderElectionConfiguration Constructor Description KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, FlinkKubeClient kubeClient, org.apache.flink.runtime.leaderelection.LeaderElectionDriver.Listener leaderElectionListener, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor) -
Uses of KubernetesLeaderElectionConfiguration in org.apache.flink.kubernetes.kubeclient
Methods in org.apache.flink.kubernetes.kubeclient with parameters of type KubernetesLeaderElectionConfiguration Modifier and Type Method Description KubernetesLeaderElectorFabric8FlinkKubeClient. createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler)KubernetesLeaderElectorFlinkKubeClient. createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler)Create a leader elector service based on Kubernetes api. -
Uses of KubernetesLeaderElectionConfiguration in org.apache.flink.kubernetes.kubeclient.resources
Constructors in org.apache.flink.kubernetes.kubeclient.resources with parameters of type KubernetesLeaderElectionConfiguration Constructor Description KubernetesLeaderElector(io.fabric8.kubernetes.client.NamespacedKubernetesClient kubernetesClient, KubernetesLeaderElectionConfiguration leaderConfig, KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler)KubernetesLeaderElector(io.fabric8.kubernetes.client.NamespacedKubernetesClient kubernetesClient, KubernetesLeaderElectionConfiguration leaderConfig, KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler, ExecutorService executorService)
-