Package org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionDriver

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriver

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.leaderelection.LeaderElectionDriver

public class KubernetesLeaderElectionDriver
extends Object
implements org.apache.flink.runtime.leaderelection.LeaderElectionDriver

LeaderElectionDriver for Kubernetes.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.leaderelection.LeaderElectionDriver

org.apache.flink.runtime.leaderelection.LeaderElectionDriver.Listener

Constructor Summary

Constructors

Constructor	Description
KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, FlinkKubeClient kubeClient, org.apache.flink.runtime.leaderelection.LeaderElectionDriver.Listener leaderElectionListener, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)

Method Summary

Modifier and Type	Method	Description
void	close()
void	deleteLeaderInformation(String componentId)
boolean	hasLeadership()
void	publishLeaderInformation(String componentId, org.apache.flink.runtime.leaderelection.LeaderInformation leaderInformation)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLeaderElectionDriver

public KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
                                      FlinkKubeClient kubeClient,
                                      org.apache.flink.runtime.leaderelection.LeaderElectionDriver.Listener leaderElectionListener,
                                      KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                      Executor watchExecutor)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

hasLeadership

public boolean hasLeadership()

Specified by:

hasLeadership in interface org.apache.flink.runtime.leaderelection.LeaderElectionDriver

publishLeaderInformation

public void publishLeaderInformation(String componentId,
                                     org.apache.flink.runtime.leaderelection.LeaderInformation leaderInformation)

Specified by:

publishLeaderInformation in interface org.apache.flink.runtime.leaderelection.LeaderElectionDriver

deleteLeaderInformation

public void deleteLeaderInformation(String componentId)

Specified by:

deleteLeaderInformation in interface org.apache.flink.runtime.leaderelection.LeaderElectionDriver

toString

public String toString()

Overrides:

toString in class Object