Class ScalingMetricEvaluator


  • public class ScalingMetricEvaluator
    extends java.lang.Object
    Job scaling evaluator for autoscaler.
    • Constructor Detail

      • ScalingMetricEvaluator

        public ScalingMetricEvaluator()
    • Method Detail

      • isProcessingBacklog

        @VisibleForTesting
        protected static boolean isProcessingBacklog​(JobTopology topology,
                                                     java.util.SortedMap<java.time.Instant,​CollectedMetrics> metricsHistory,
                                                     org.apache.flink.configuration.Configuration conf)
      • computeProcessingRateThresholds

        @VisibleForTesting
        protected static void computeProcessingRateThresholds​(java.util.Map<ScalingMetric,​EvaluatedScalingMetric> metrics,
                                                              org.apache.flink.configuration.Configuration conf,
                                                              boolean processingBacklog)