Class AutoScalerUtils


  • public class AutoScalerUtils
    extends java.lang.Object
    AutoScaler utilities.
    • Constructor Detail

      • AutoScalerUtils

        public AutoScalerUtils()
    • Method Detail

      • getTargetProcessingCapacity

        public static double getTargetProcessingCapacity​(java.util.Map<ScalingMetric,​EvaluatedScalingMetric> evaluatedMetrics,
                                                         org.apache.flink.configuration.Configuration conf,
                                                         double targetUtilization,
                                                         boolean withRestart)