Package | Description |
---|---|
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.kubeclient.resources |
Modifier and Type | Method and Description |
---|---|
KubernetesLeaderElector |
Fabric8FlinkKubeClient.createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler) |
KubernetesLeaderElector |
FlinkKubeClient.createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler)
Create a leader elector service based on Kubernetes api.
|
Constructor and Description |
---|
KubernetesLeaderElector(io.fabric8.kubernetes.client.NamespacedKubernetesClient kubernetesClient,
KubernetesLeaderElectionConfiguration leaderConfig,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.