Package org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderRetrievalDriverFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriverFactory

All Implemented Interfaces:

LeaderRetrievalDriverFactory

public class KubernetesLeaderRetrievalDriverFactory
extends Object
implements LeaderRetrievalDriverFactory

Factory that instantiates a KubernetesLeaderRetrievalDriver in single leader election mode.

Constructor Summary

Constructors

Constructor	Description
KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName, String componentId)

Method Summary

Modifier and Type	Method	Description
LeaderRetrievalDriver	createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler)	Create a specific LeaderRetrievalDriver and start the necessary services.
LeaderInformation	extractLeaderInformation(KubernetesConfigMap configMap)

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,
                                              String componentId)

Method Detail

createLeaderRetrievalDriver

public LeaderRetrievalDriver createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
                                                         FatalErrorHandler fatalErrorHandler)

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

extractLeaderInformation

public LeaderInformation extractLeaderInformation(KubernetesConfigMap configMap)