Interface | Description |
---|---|
LeaderContender |
Interface which has to be implemented to take part in the leader election process of the
LeaderElectionService . |
LeaderElectionDriver |
A
LeaderElectionDriver is responsible for performing the leader election and storing the
leader information. |
LeaderElectionDriverFactory |
Factory for creating
LeaderElectionDriver with different implementation. |
LeaderElectionEventHandler |
Interface which should be implemented to respond to leader changes in
LeaderElectionDriver . |
LeaderElectionService |
Interface for a service which allows to elect a leader among a group of contenders.
|
MultipleComponentLeaderElectionDriver |
A leader election driver that allows to write
LeaderInformation for multiple components. |
MultipleComponentLeaderElectionDriver.Listener |
Listener interface for state changes of the
MultipleComponentLeaderElectionDriver . |
MultipleComponentLeaderElectionDriverFactory |
Factory for
MultipleComponentLeaderElectionDriver . |
MultipleComponentLeaderElectionService |
Leader election service that allows to register multiple
LeaderElectionEventHandlers that are identified by different names. |
Class | Description |
---|---|
DefaultLeaderElectionService |
Default implementation for leader election service.
|
DefaultMultipleComponentLeaderElectionService |
Default implementation of a
MultipleComponentLeaderElectionService that allows to
register multiple LeaderElectionEventHandler . |
LeaderInformation |
Information about leader including the confirmed leader session id and leader address.
|
LeaderInformationWithComponentId |
Leader information and its corresponding leader name.
|
StandaloneLeaderElectionService |
Standalone implementation of the
LeaderElectionService interface. |
ZooKeeperLeaderElectionDriver | Deprecated
in favour of
ZooKeeperMultipleComponentLeaderElectionDriver |
ZooKeeperLeaderElectionDriverFactory | Deprecated |
ZooKeeperMultipleComponentLeaderElectionDriver |
ZooKeeper based
MultipleComponentLeaderElectionDriver implementation. |
ZooKeeperMultipleComponentLeaderElectionDriverFactory |
Factory for
ZooKeeperMultipleComponentLeaderElectionDriver . |
Exception | Description |
---|---|
LeaderElectionException |
This exception is thrown by the
LeaderElectionDriver when LeaderElectionDriver.writeLeaderInformation(org.apache.flink.runtime.leaderelection.LeaderInformation) failed or some unexpected changes to the leader
storage. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.