public class ZooKeeperLeaderElectionDriver extends Object implements LeaderElectionDriver, org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.leader.LeaderLatchListener
LeaderElectionDriver
implementation.LeaderElectionDriver.Listener
Constructor and Description |
---|
ZooKeeperLeaderElectionDriver(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework curatorFramework,
LeaderElectionDriver.Listener leaderElectionListener) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
deleteLeaderInformation(String componentId)
Deletes the leader information for the given component.
|
boolean |
hasLeadership()
Returns whether the driver has currently leadership.
|
void |
isLeader() |
void |
notLeader() |
void |
publishLeaderInformation(String componentId,
LeaderInformation leaderInformation)
Publishes the leader information for the given component.
|
String |
toString() |
public ZooKeeperLeaderElectionDriver(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework curatorFramework, LeaderElectionDriver.Listener leaderElectionListener) throws Exception
Exception
public void close() throws Exception
close
in interface AutoCloseable
Exception
public boolean hasLeadership()
LeaderElectionDriver
hasLeadership
in interface LeaderElectionDriver
true
if the driver has leadership, otherwise false
public void publishLeaderInformation(String componentId, LeaderInformation leaderInformation)
LeaderElectionDriver
publishLeaderInformation
in interface LeaderElectionDriver
componentId
- identifying the component for which to publish the leader informationleaderInformation
- leader information of the respective componentpublic void deleteLeaderInformation(String componentId)
LeaderElectionDriver
deleteLeaderInformation
in interface LeaderElectionDriver
componentId
- identifying the component for which to delete the leader informationpublic void isLeader()
isLeader
in interface org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.leader.LeaderLatchListener
public void notLeader()
notLeader
in interface org.apache.flink.shaded.curator5.org.apache.curator.framework.recipes.leader.LeaderLatchListener
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.