Uses of Class
org.apache.flink.kubernetes.kubeclient.resources.KubernetesConfigMap

Packages that use KubernetesConfigMap

Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.kubernetes.kubeclient
org.apache.flink.kubernetes.kubeclient.resources
org.apache.flink.kubernetes.utils

Uses of KubernetesConfigMap in org.apache.flink.kubernetes.highavailability

Methods in org.apache.flink.kubernetes.highavailability with parameters of type KubernetesConfigMap

Modifier and Type	Method	Description
org.apache.flink.runtime.leaderelection.LeaderInformation	KubernetesLeaderRetrievalDriverFactory.extractLeaderInformation(KubernetesConfigMap configMap)

Constructor parameters in org.apache.flink.kubernetes.highavailability with type arguments of type KubernetesConfigMap

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)

Uses of KubernetesConfigMap in org.apache.flink.kubernetes.kubeclient

Methods in org.apache.flink.kubernetes.kubeclient that return types with arguments of type KubernetesConfigMap

Modifier and Type	Method	Description
Optional<KubernetesConfigMap>	Fabric8FlinkKubeClient.getConfigMap(String name)
Optional<KubernetesConfigMap>	FlinkKubeClient.getConfigMap(String name)	Get the ConfigMap with specified name.

Methods in org.apache.flink.kubernetes.kubeclient with parameters of type KubernetesConfigMap

Modifier and Type	Method	Description
CompletableFuture<Void>	Fabric8FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap)
CompletableFuture<Void>	FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap)	Create the ConfigMap with specified content.

Method parameters in org.apache.flink.kubernetes.kubeclient with type arguments of type KubernetesConfigMap

Modifier and Type	Method	Description
CompletableFuture<Boolean>	Fabric8FlinkKubeClient.checkAndUpdateConfigMap(String configMapName, Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)
CompletableFuture<Boolean>	Fabric8FlinkKubeClient.checkAndUpdateConfigMap(String configMapName, Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)
CompletableFuture<Boolean>	FlinkKubeClient.checkAndUpdateConfigMap(String configMapName, Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)	Update an existing ConfigMap with the data.
CompletableFuture<Boolean>	FlinkKubeClient.checkAndUpdateConfigMap(String configMapName, Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)	Update an existing ConfigMap with the data.

Uses of KubernetesConfigMap in org.apache.flink.kubernetes.kubeclient.resources

Methods in org.apache.flink.kubernetes.kubeclient.resources with parameters of type KubernetesConfigMap

Modifier and Type	Method	Description
static boolean	KubernetesLeaderElector.hasLeadership(KubernetesConfigMap configMap, String lockIdentity)

Uses of KubernetesConfigMap in org.apache.flink.kubernetes.utils

Methods in org.apache.flink.kubernetes.utils that return KubernetesConfigMap

Modifier and Type	Method	Description
static KubernetesConfigMap	KubernetesUtils.getOnlyConfigMap(List<KubernetesConfigMap> configMaps, String expectedConfigMapName)	Check the ConfigMap list should only contain the expected one.

Methods in org.apache.flink.kubernetes.utils with parameters of type KubernetesConfigMap

Modifier and Type	Method	Description
static org.apache.flink.runtime.leaderelection.LeaderInformation	KubernetesUtils.getLeaderInformationFromConfigMap(KubernetesConfigMap configMap)	Get the LeaderInformation from ConfigMap.

Method parameters in org.apache.flink.kubernetes.utils with type arguments of type KubernetesConfigMap

Modifier and Type	Method	Description
static KubernetesConfigMap	KubernetesUtils.getOnlyConfigMap(List<KubernetesConfigMap> configMaps, String expectedConfigMapName)	Check the ConfigMap list should only contain the expected one.