Package org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderRetrievalDriver

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriver

All Implemented Interfaces:

AutoCloseable, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalDriver

public class KubernetesLeaderRetrievalDriver
extends Object
implements org.apache.flink.runtime.leaderretrieval.LeaderRetrievalDriver

The counterpart to the KubernetesLeaderElectionDriver. LeaderRetrievalDriver implementation for Kubernetes. It retrieves the current leader which has been elected by the KubernetesLeaderElectionDriver. The leader address as well as the current leader session ID is retrieved from Kubernetes ConfigMap.

Constructor Summary

Constructors

Constructor

Description

KubernetesLeaderRetrievalDriver(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalEventHandler leaderRetrievalEventHandler, Function<KubernetesConfigMap,org.apache.flink.runtime.leaderelection.LeaderInformation> leaderInformationExtractor, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)

Method Summary

Modifier and Type	Method	Description
void	close()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLeaderRetrievalDriver

public KubernetesLeaderRetrievalDriver(KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                       Executor watchExecutor,
                                       String configMapName,
                                       org.apache.flink.runtime.leaderretrieval.LeaderRetrievalEventHandler leaderRetrievalEventHandler,
                                       Function<KubernetesConfigMap,org.apache.flink.runtime.leaderelection.LeaderInformation> leaderInformationExtractor,
                                       org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

toString

public String toString()

Overrides:

toString in class Object