org.apache.flink.runtime.leaderelection

Class ZooKeeperLeaderElectionDriverFactory

java.lang.Object

org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionDriverFactory

All Implemented Interfaces:

LeaderElectionDriverFactory

public class ZooKeeperLeaderElectionDriverFactory
extends Object
implements LeaderElectionDriverFactory

LeaderElectionDriverFactory implementation for Zookeeper.

Constructor Summary

Constructors

Constructor and Description
ZooKeeperLeaderElectionDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, String latchPath, String leaderPath)

Method Summary

Modifier and Type	Method and Description
ZooKeeperLeaderElectionDriver	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

ZooKeeperLeaderElectionDriverFactory

public ZooKeeperLeaderElectionDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client,
                                            String latchPath,
                                            String leaderPath)

Method Detail

createLeaderElectionDriver

public ZooKeeperLeaderElectionDriver createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
                                                                FatalErrorHandler fatalErrorHandler,
                                                                String leaderContenderDescription)
                                                         throws Exception

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.

Throws:

Exception - when create a specific LeaderElectionDriver implementation and start the necessary services.