Package org.apache.flink.kubernetes.operator.autoscaler.state

Class ConfigMapStore

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

public class ConfigMapStore
extends java.lang.Object

The ConfigMapStore persists state in Kubernetes ConfigMaps.

Constructor Summary

Constructors

Constructor	Description
ConfigMapStore(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

Method Summary

Modifier and Type	Method	Description
void	clearAll(KubernetesJobAutoScalerContext jobContext)
void	flush(KubernetesJobAutoScalerContext jobContext)
protected java.util.concurrent.ConcurrentHashMap<io.javaoperatorsdk.operator.processing.event.ResourceID,org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapView>	getCache()
protected java.util.Optional<java.lang.String>	getSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)
protected void	putSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key, java.lang.String value)
void	removeInfoFromCache(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID)
protected void	removeSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigMapStore

public ConfigMapStore(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

Method Detail

putSerializedState

protected void putSerializedState(KubernetesJobAutoScalerContext jobContext,
                                  java.lang.String key,
                                  java.lang.String value)

getSerializedState

protected java.util.Optional<java.lang.String> getSerializedState(KubernetesJobAutoScalerContext jobContext,
                                                                  java.lang.String key)

removeSerializedState

protected void removeSerializedState(KubernetesJobAutoScalerContext jobContext,
                                     java.lang.String key)

clearAll

public void clearAll(KubernetesJobAutoScalerContext jobContext)

flush

public void flush(KubernetesJobAutoScalerContext jobContext)

removeInfoFromCache

public void removeInfoFromCache(io.javaoperatorsdk.operator.processing.event.ResourceID resourceID)

getCache

@VisibleForTesting
protected java.util.concurrent.ConcurrentHashMap<io.javaoperatorsdk.operator.processing.event.ResourceID,org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapView> getCache()