KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
ExecutorService watchExecutorService,
KubernetesLeaderElectionConfiguration leaderConfig,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler)
Deprecated.
|
KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
ExecutorService watchExecutorService,
KubernetesLeaderElectionConfiguration leaderConfig)
Deprecated.
|
KubernetesLeaderRetrievalDriver(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
java.util.function.Function<KubernetesConfigMap,LeaderInformation> leaderInformationExtractor,
FatalErrorHandler fatalErrorHandler) |
KubernetesLeaderRetrievalDriverFactory(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName)
Deprecated.
|
KubernetesMultipleComponentLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
FlinkKubeClient kubeClient,
MultipleComponentLeaderElectionDriver.Listener leaderElectionListener,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
FatalErrorHandler fatalErrorHandler) |
KubernetesMultipleComponentLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
FatalErrorHandler fatalErrorHandler) |
KubernetesMultipleComponentLeaderRetrievalDriverFactory(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName,
String componentId) |