org.apache.flink.runtime.leaderelection

Interface LeaderElectionDriverFactory

All Known Implementing Classes:

KubernetesLeaderElectionDriverFactory, ZooKeeperLeaderElectionDriverFactory

public interface LeaderElectionDriverFactory

Factory for creating LeaderElectionDriver with different implementation.

Method Summary

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

Method Detail

createLeaderElectionDriver

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

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

Parameters:

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

leaderContenderDescription - leader contender description.

fatalErrorHandler - fatal error handler

Throws:

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