Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.runtime.leaderelection |
Modifier and Type | Method and Description |
---|---|
KubernetesLeaderElectionDriver |
KubernetesLeaderElectionDriverFactory.createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription) |
Constructor and Description |
---|
KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
ExecutorService watchExecutorService,
KubernetesLeaderElectionConfiguration leaderConfig,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultLeaderElectionService
Default implementation for leader election service.
|
Modifier and Type | Method and Description |
---|---|
ZooKeeperLeaderElectionDriver |
ZooKeeperLeaderElectionDriverFactory.createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription) |
LeaderElectionDriver |
LeaderElectionDriverFactory.createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription)
Create a specific
LeaderElectionDriver and start the necessary services. |
Constructor and Description |
---|
ZooKeeperLeaderElectionDriver(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client,
String path,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription)
Creates a ZooKeeperLeaderElectionDriver object.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.