org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderRetrievalDriverFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriverFactory

All Implemented Interfaces:

LeaderRetrievalDriverFactory

Deprecated.

in favour of KubernetesMultipleComponentLeaderRetrievalDriverFactory

@Deprecated
public class KubernetesLeaderRetrievalDriverFactory
extends Object
implements LeaderRetrievalDriverFactory

LeaderRetrievalDriverFactory implementation for Kubernetes.

Constructor Summary

Constructors

Constructor and Description
KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName) Deprecated.

Method Summary

Modifier and Type	Method and Description
KubernetesLeaderRetrievalDriver	createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler) Deprecated. Create a specific LeaderRetrievalDriver and start the necessary services.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KubernetesLeaderRetrievalDriverFactory

public KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                              Executor watchExecutor,
                                              String configMapName)

Deprecated.

Method Detail

createLeaderRetrievalDriver

public KubernetesLeaderRetrievalDriver createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
                                                                   FatalErrorHandler fatalErrorHandler)

Deprecated.

Description copied from interface: LeaderRetrievalDriverFactory

Create a specific LeaderRetrievalDriver and start the necessary services. For example, NodeCache in Zookeeper, ConfigMap watcher in Kubernetes. They could get the leader information change events and need to notify the leader listener by LeaderRetrievalEventHandler.

Specified by:

createLeaderRetrievalDriver in interface LeaderRetrievalDriverFactory

Parameters:

leaderEventHandler - handler for the leader retrieval driver to notify leader change events.

fatalErrorHandler - fatal error handler