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

Class AutoScalerInfo

  • public class AutoScalerInfo
extends java.lang.Object
    Class for encapsulating information stored for each resource when using the autoscaler.

    • Field Detail

      • COLLECTED_METRICS_KEY

        protected static final java.lang.String COLLECTED_METRICS_KEY
        See Also:
        Constant Field Values

      • SCALING_HISTORY_KEY

        protected static final java.lang.String SCALING_HISTORY_KEY
        See Also:
        Constant Field Values

      • PARALLELISM_OVERRIDES_KEY

        protected static final java.lang.String PARALLELISM_OVERRIDES_KEY
        See Also:
        Constant Field Values

      • YAML_MAPPER

        protected static final com.fasterxml.jackson.databind.ObjectMapper YAML_MAPPER

    • 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,​CollectedMetrics> getMetricHistory()

      • updateMetricHistory

        public void updateMetricHistory​(java.util.SortedMap<java.time.Instant,​CollectedMetrics> history)

      • updateVertexList

        public void updateVertexList​(java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> vertexList,
                             java.time.Instant now,
                             org.apache.flink.configuration.Configuration conf)

      • clearMetricHistory

        public void clearMetricHistory()

      • getScalingHistory

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

      • 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)

      • setCurrentOverrides

        public void setCurrentOverrides​(java.util.Map<java.lang.String,​java.lang.String> overrides)

      • getCurrentOverrides

        public java.util.Map<java.lang.String,​java.lang.String> getCurrentOverrides()

      • removeCurrentOverrides

        public void removeCurrentOverrides()

      • replaceInKubernetes

        public void replaceInKubernetes​(io.fabric8.kubernetes.client.KubernetesClient client)
                         throws java.lang.Exception
        Throws:
        java.lang.Exception

      • isValid

        public boolean isValid()

      • trimHistoryToMaxCmSize

        @VisibleForTesting
protected void trimHistoryToMaxCmSize()
                               throws java.lang.Exception
        Throws:
        java.lang.Exception

      • getConfigMap

        @VisibleForTesting
protected io.fabric8.kubernetes.api.model.ConfigMap getConfigMap()