org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionDriverFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriverFactory

All Implemented Interfaces:

LeaderElectionDriverFactory

public class KubernetesLeaderElectionDriverFactory
extends Object
implements LeaderElectionDriverFactory

LeaderElectionDriverFactory implementation for Kubernetes.

Constructor Summary

Constructors

Constructor and Description
KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesLeaderElectionConfiguration leaderConfig)

Method Summary

Modifier and Type	Method and Description
KubernetesLeaderElectionDriver	createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler, String leaderContenderDescription) 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,
                                             KubernetesLeaderElectionConfiguration leaderConfig)

Method Detail

createLeaderElectionDriver

public KubernetesLeaderElectionDriver createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
                                                                 FatalErrorHandler fatalErrorHandler,
                                                                 String leaderContenderDescription)

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

leaderContenderDescription - leader contender description.