Uses of Interface
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalDriver
-
Packages that use LeaderRetrievalDriver Package Description org.apache.flink.kubernetes.highavailability org.apache.flink.runtime.leaderretrieval -
-
Uses of LeaderRetrievalDriver in org.apache.flink.kubernetes.highavailability
Classes in org.apache.flink.kubernetes.highavailability that implement LeaderRetrievalDriver Modifier and Type Class Description class
KubernetesLeaderRetrievalDriver
The counterpart to theKubernetesLeaderElectionDriver
.Methods in org.apache.flink.kubernetes.highavailability that return LeaderRetrievalDriver Modifier and Type Method Description LeaderRetrievalDriver
KubernetesLeaderRetrievalDriverFactory. createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler)
-
Uses of LeaderRetrievalDriver in org.apache.flink.runtime.leaderretrieval
Classes in org.apache.flink.runtime.leaderretrieval that implement LeaderRetrievalDriver Modifier and Type Class Description class
ZooKeeperLeaderRetrievalDriver
The counterpart to theZooKeeperLeaderElectionDriver
.Methods in org.apache.flink.runtime.leaderretrieval that return LeaderRetrievalDriver Modifier and Type Method Description LeaderRetrievalDriver
LeaderRetrievalDriverFactory. createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler)
Create a specificLeaderRetrievalDriver
and start the necessary services.
-