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)
java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>>	evaluate(org.apache.flink.configuration.Configuration conf, CollectedMetrics collectedMetrics)
protected void	setClock(java.time.Clock clock)

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,
                                                                                                                                             CollectedMetrics collectedMetrics)

computeProcessingRateThresholds

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

setClock

@VisibleForTesting
protected void setClock(java.time.Clock clock)