Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.leaderretrieval |
Modifier and Type | Method and Description |
---|---|
KubernetesLeaderRetrievalDriver |
KubernetesLeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler)
Deprecated.
|
LeaderRetrievalDriver |
KubernetesMultipleComponentLeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
KubernetesLeaderRetrievalDriver(KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
java.util.function.Function<KubernetesConfigMap,LeaderInformation> leaderInformationExtractor,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultLeaderRetrievalService
The counterpart to the
DefaultLeaderElectionService . |
Modifier and Type | Method and Description |
---|---|
ZooKeeperLeaderRetrievalDriver |
ZooKeeperLeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler) |
LeaderRetrievalDriver |
LeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler)
Create a specific
LeaderRetrievalDriver and start the necessary services. |
Constructor and Description |
---|
ZooKeeperLeaderRetrievalDriver(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client,
String path,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
ZooKeeperLeaderRetrievalDriver.LeaderInformationClearancePolicy leaderInformationClearancePolicy,
FatalErrorHandler fatalErrorHandler)
Creates a leader retrieval service which uses ZooKeeper to retrieve the leader information.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.