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

Class ScalingMetrics

  • public class ScalingMetrics
extends java.lang.Object
    Utilities for computing scaling metrics based on Flink metrics.

    • Constructor Summary

      Constructors 
      Constructor Description
      ScalingMetrics()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void computeDataRateMetrics​(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics, JobTopology topology, java.util.Optional<java.lang.Double> lagGrowthOpt, org.apache.flink.configuration.Configuration conf)  
      static void computeLagMetrics​(java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics)  
      static void computeLoadMetrics​(java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ScalingMetrics

        public ScalingMetrics()

    • Method Detail

      • computeLoadMetrics

        public static void computeLoadMetrics​(java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics,
                                      java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics)

      • computeDataRateMetrics

        public static void computeDataRateMetrics​(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID,
                                          java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics,
                                          java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics,
                                          JobTopology topology,
                                          java.util.Optional<java.lang.Double> lagGrowthOpt,
                                          org.apache.flink.configuration.Configuration conf)

      • computeLagMetrics

        public static void computeLagMetrics​(java.util.Map<FlinkMetric,​org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics,
                                     java.util.Map<ScalingMetric,​java.lang.Double> scalingMetrics)