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

Class AutoScalerUtils

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

    • Constructor Summary

      Constructors 
      Constructor Description
      AutoScalerUtils()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static boolean excludeVertexFromScaling​(org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId)
      Temporarily exclude vertex from scaling for this run.
      static boolean excludeVerticesFromScaling​(org.apache.flink.configuration.Configuration conf, java.util.Collection<org.apache.flink.runtime.jobgraph.JobVertexID> ids)  
      static double getTargetProcessingCapacity​(java.util.Map<ScalingMetric,​EvaluatedScalingMetric> evaluatedMetrics, org.apache.flink.configuration.Configuration conf, double targetUtilization, boolean withRestart)  

      • Methods inherited from class java.lang.Object

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

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

      • excludeVertexFromScaling

        public static boolean excludeVertexFromScaling​(org.apache.flink.configuration.Configuration conf,
                                               org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId)
        Temporarily exclude vertex from scaling for this run. This does not update the spec.

      • excludeVerticesFromScaling

        public static boolean excludeVerticesFromScaling​(org.apache.flink.configuration.Configuration conf,
                                                 java.util.Collection<org.apache.flink.runtime.jobgraph.JobVertexID> ids)