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

Class AutoScalerInfo

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

public class AutoScalerInfo
extends java.lang.Object

Class for encapsulating information stored for each resource when using the autoscaler.

Constructor Summary

Constructors

Constructor	Description
AutoScalerInfo(io.fabric8.kubernetes.api.model.ConfigMap configMap)
AutoScalerInfo(java.util.Map<java.lang.String,java.lang.String> data)

Method Summary

Modifier and Type	Method	Description
void	addToScalingHistory(java.time.Instant now, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> summaries, org.apache.flink.configuration.Configuration conf)
void	clearMetricHistory()
static AutoScalerInfo	forResource(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubeClient)
java.util.Optional<java.time.Instant>	getJobUpdateTs()
java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>>	getMetricHistory()
java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>>	getScalingHistory()
void	replaceInKubernetes(io.fabric8.kubernetes.client.KubernetesClient client)
void	updateMetricHistory(java.time.Instant jobUpdateTs, java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>> history)
void	updateVertexList(java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> vertexList)

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoScalerInfo

public AutoScalerInfo(io.fabric8.kubernetes.api.model.ConfigMap configMap)

AutoScalerInfo

@VisibleForTesting
public AutoScalerInfo(java.util.Map<java.lang.String,java.lang.String> data)

Method Detail

getMetricHistory

public java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>> getMetricHistory()

updateMetricHistory

public void updateMetricHistory(java.time.Instant jobUpdateTs,
                                java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>> history)

updateVertexList

public void updateVertexList(java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> vertexList)

clearMetricHistory

public void clearMetricHistory()

getJobUpdateTs

public java.util.Optional<java.time.Instant> getJobUpdateTs()

getScalingHistory

public java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> getScalingHistory()

addToScalingHistory

public void addToScalingHistory(java.time.Instant now,
                                java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> summaries,
                                org.apache.flink.configuration.Configuration conf)

replaceInKubernetes

public void replaceInKubernetes(io.fabric8.kubernetes.client.KubernetesClient client)

forResource

public static AutoScalerInfo forResource(AbstractFlinkResource<?,?> cr,
                                         io.fabric8.kubernetes.client.KubernetesClient kubeClient)