org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionDriverFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriverFactory

All Implemented Interfaces:

LeaderElectionDriverFactory

Deprecated.

in favour of KubernetesMultipleComponentLeaderElectionDriverFactory

public class KubernetesLeaderElectionDriverFactory
extends Object
implements LeaderElectionDriverFactory

LeaderElectionDriverFactory implementation for Kubernetes.

Constructor Summary

Constructors

Constructor and Description
KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesConfigMapSharedWatcher configMapSharedWatcher, ExecutorService watchExecutorService, KubernetesLeaderElectionConfiguration leaderConfig) Deprecated.

Method Summary

Modifier and Type	Method and Description
KubernetesLeaderElectionDriver	createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler) Deprecated. Create a specific LeaderElectionDriver and start the necessary services.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KubernetesLeaderElectionDriverFactory

public KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
                                             KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                             ExecutorService watchExecutorService,
                                             KubernetesLeaderElectionConfiguration leaderConfig)

Deprecated.

Method Detail

createLeaderElectionDriver

public KubernetesLeaderElectionDriver createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
                                                                 FatalErrorHandler fatalErrorHandler)

Deprecated.

Description copied from interface: LeaderElectionDriverFactory

Create a specific LeaderElectionDriver and start the necessary services. For example, LeaderLatch and NodeCache in Zookeeper, KubernetesLeaderElector and ConfigMap watcher in Kubernetes.

Specified by:

createLeaderElectionDriver in interface LeaderElectionDriverFactory

Parameters:

leaderEventHandler - handler for the leader election driver to process leader events.

fatalErrorHandler - fatal error handler