Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.leaderretrieval |
Modifier and Type | Class and Description |
---|---|
class |
KubernetesLeaderRetrievalDriver
The counterpart to the
KubernetesLeaderElectionDriver . |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalDriver |
KubernetesMultipleComponentLeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Class and Description |
---|---|
class |
ZooKeeperLeaderRetrievalDriver
The counterpart to the
ZooKeeperLeaderElectionDriver . |
Modifier and Type | Method and Description |
---|---|
LeaderRetrievalDriver |
LeaderRetrievalDriverFactory.createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler)
Create a specific
LeaderRetrievalDriver and start the necessary services. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.