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

Class ScalingMetricEvaluator

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator

public class ScalingMetricEvaluator
extends java.lang.Object

Job scaling evaluator for autoscaler.

Constructor Summary

Constructors

Constructor	Description
ScalingMetricEvaluator()

Method Summary

Modifier and Type	Method	Description
protected static void	computeProcessingRateThresholds(java.util.Map<ScalingMetric,EvaluatedScalingMetric> metrics, org.apache.flink.configuration.Configuration conf, boolean processingBacklog)
java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>>	evaluate(org.apache.flink.configuration.Configuration conf, CollectedMetricHistory collectedMetrics)
protected static boolean	isProcessingBacklog(JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.configuration.Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalingMetricEvaluator

public ScalingMetricEvaluator()

Method Detail

evaluate

public java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluate(org.apache.flink.configuration.Configuration conf,
                                                                                                                                             CollectedMetricHistory collectedMetrics)

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)