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)
Deprecated.
|
Constructor and Description |
---|
KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
ExecutorService watchExecutorService,
KubernetesLeaderElectionConfiguration leaderConfig,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultLeaderElectionService
Default implementation for leader election service.
|
Modifier and Type | Method and Description |
---|---|
LeaderElectionDriver |
LeaderElectionDriverFactory.createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription)
Create a specific
LeaderElectionDriver and start the necessary services. |
ZooKeeperLeaderElectionDriver |
ZooKeeperLeaderElectionDriverFactory.createLeaderElectionDriver(LeaderElectionEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription)
Deprecated.
|
void |
DefaultMultipleComponentLeaderElectionService.registerLeaderElectionEventHandler(String componentId,
LeaderElectionEventHandler leaderElectionEventHandler) |
void |
MultipleComponentLeaderElectionService.registerLeaderElectionEventHandler(String componentId,
LeaderElectionEventHandler leaderElectionEventHandler)
Registers a new leader election event handler under the given component id.
|
Constructor and Description |
---|
ZooKeeperLeaderElectionDriver(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client,
String path,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler,
String leaderContenderDescription)
Deprecated.
Creates a ZooKeeperLeaderElectionDriver object.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.