Package org.apache.flink.autoscaler

Class ScalingMetricEvaluator

java.lang.Object

org.apache.flink.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)
static double	getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
static double	getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, int minElements)
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)

getAverage

public static double getAverage(ScalingMetric metric,
                                org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId,
                                java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)

getAverage

public static double getAverage(ScalingMetric metric,
                                org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId,
                                java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory,
                                int minElements)