Package org.apache.flink.kubernetes.configuration

Class KubernetesLeaderElectionConfiguration

java.lang.Object

org.apache.flink.kubernetes.configuration.KubernetesLeaderElectionConfiguration

public class KubernetesLeaderElectionConfiguration
extends Object

Configuration specific to KubernetesLeaderElector.

Constructor Summary

Constructors

Constructor	Description
KubernetesLeaderElectionConfiguration(String configMapName, String lockIdentity, org.apache.flink.configuration.Configuration config)

Method Summary

Modifier and Type	Method	Description
String	getClusterId()
String	getConfigMapName()
java.time.Duration	getLeaseDuration()
String	getLockIdentity()
java.time.Duration	getRenewDeadline()
java.time.Duration	getRetryPeriod()

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLeaderElectionConfiguration

public KubernetesLeaderElectionConfiguration(String configMapName,
                                             String lockIdentity,
                                             org.apache.flink.configuration.Configuration config)

Method Detail

getClusterId

public String getClusterId()

getConfigMapName

public String getConfigMapName()

getLockIdentity

public String getLockIdentity()

getLeaseDuration

public java.time.Duration getLeaseDuration()

getRenewDeadline

public java.time.Duration getRenewDeadline()

getRetryPeriod

public java.time.Duration getRetryPeriod()