org.apache.flink.kubernetes.highavailability

Class KubernetesMultipleComponentLeaderElectionDriverFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesMultipleComponentLeaderElectionDriverFactory

All Implemented Interfaces:

MultipleComponentLeaderElectionDriverFactory

public class KubernetesMultipleComponentLeaderElectionDriverFactory
extends Object
implements MultipleComponentLeaderElectionDriverFactory

Factory that instantiates a KubernetesMultipleComponentLeaderElectionDriver.

Constructor Summary

Constructors

Constructor and Description
KubernetesMultipleComponentLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, FatalErrorHandler fatalErrorHandler)

Method Summary

Modifier and Type	Method and Description
KubernetesMultipleComponentLeaderElectionDriver	create(MultipleComponentLeaderElectionDriver.Listener leaderElectionListener) Creates a MultipleComponentLeaderElectionDriver for the given leader contender description.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesMultipleComponentLeaderElectionDriverFactory

public KubernetesMultipleComponentLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
                                                              KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration,
                                                              KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                                              Executor watchExecutor,
                                                              FatalErrorHandler fatalErrorHandler)

Method Detail

create

public KubernetesMultipleComponentLeaderElectionDriver create(MultipleComponentLeaderElectionDriver.Listener leaderElectionListener)
                                                       throws Exception

Description copied from interface: MultipleComponentLeaderElectionDriverFactory

Creates a MultipleComponentLeaderElectionDriver for the given leader contender description. Moreover, it registers the given leader election listener with the service.

Specified by:

create in interface MultipleComponentLeaderElectionDriverFactory

Parameters:

leaderElectionListener - listener for the callbacks of the MultipleComponentLeaderElectionDriver

Returns:

created MultipleComponentLeaderElectionDriver instance

Throws:

Exception - if the creation fails