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) |
Constructor and Description |
---|
KubernetesLeaderRetrievalDriver(FlinkKubeClient kubeClient,
String configMapName,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultLeaderRetrievalService
The counterpart to the
DefaultLeaderElectionService . |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalDriver |
LeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler)
Create a specific
LeaderRetrievalDriver and start the necessary services. |
ZooKeeperLeaderRetrievalDriver |
ZooKeeperLeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler) |
Constructor and Description |
---|
ZooKeeperLeaderRetrievalDriver(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client,
String retrievalPath,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
FatalErrorHandler fatalErrorHandler)
Creates a leader retrieval service which uses ZooKeeper to retrieve the leader information.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.