Package org.apache.flink.runtime.leaderelection
-
Interface Summary Interface Description LeaderContender Interface which has to be implemented to take part in the leader election process of theLeaderElectionService
.LeaderElection LeaderElectionDriver A leader election driver that allows to writeLeaderInformation
for multiple components.LeaderElectionDriver.Listener Listener interface for state changes of theLeaderElectionDriver
.LeaderElectionDriverFactory Factory forLeaderElectionDriver
.LeaderElectionService Interface for a service which allows to elect a leader among a group of contenders. -
Class Summary Class Description DefaultLeaderElectionService Default implementation for leader election service.LeaderElectionUtils LeaderElectionUtils
collects helper methods to handle LeaderElection-related issues.LeaderInformation Information about leader including the confirmed leader session id and leader address.LeaderInformationRegister A register containing theLeaderInformation
for multiple contenders based on theircomponentId
.StandaloneLeaderElection StandaloneLeaderElection
implementsLeaderElection
for non-HA cases.ZooKeeperLeaderElectionDriver ZooKeeper basedLeaderElectionDriver
implementation.ZooKeeperLeaderElectionDriverFactory Factory forZooKeeperLeaderElectionDriver
. -
Exception Summary Exception Description LeaderElectionException This exception is used in leader election-related scenarios.LeadershipLostException This exception is used in the scenario that the leadership is lost.