Uses of Class
org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric

Packages that use EvaluatedScalingMetric

Package	Description
org.apache.flink.autoscaler
org.apache.flink.autoscaler.metrics
org.apache.flink.autoscaler.utils

Uses of EvaluatedScalingMetric in org.apache.flink.autoscaler

Methods in org.apache.flink.autoscaler that return types with arguments of type EvaluatedScalingMetric

Modifier and Type	Method	Description
protected static java.util.Map<ScalingMetric,EvaluatedScalingMetric>	ScalingMetricEvaluator.evaluateGlobalMetrics(java.util.SortedMap<java.time.Instant,CollectedMetrics> metricHistory)

Method parameters in org.apache.flink.autoscaler with type arguments of type EvaluatedScalingMetric

Modifier and Type	Method	Description
protected static boolean	ScalingExecutor.allVerticesWithinUtilizationTarget(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries)
protected static void	ScalingMetricEvaluator.computeProcessingRateThresholds(java.util.Map<ScalingMetric,EvaluatedScalingMetric> metrics, org.apache.flink.configuration.Configuration conf, boolean processingBacklog, java.time.Duration restartTime)
int	JobVertexScaler.computeScaleTargetParallelism(Context context, org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.util.Collection<ShipStrategy> inputShipStrategies, java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, java.util.SortedMap<java.time.Instant,ScalingSummary> history, java.time.Duration restartTime)

Constructor parameters in org.apache.flink.autoscaler with type arguments of type EvaluatedScalingMetric

Constructor	Description
ScalingSummary(int currentParallelism, int newParallelism, java.util.Map<ScalingMetric,EvaluatedScalingMetric> metrics)

Uses of EvaluatedScalingMetric in org.apache.flink.autoscaler.metrics

Methods in org.apache.flink.autoscaler.metrics that return EvaluatedScalingMetric

Modifier and Type	Method	Description
static EvaluatedScalingMetric	EvaluatedScalingMetric.avg(double average)
static EvaluatedScalingMetric	EvaluatedScalingMetric.of(double current)

Method parameters in org.apache.flink.autoscaler.metrics with type arguments of type EvaluatedScalingMetric

Modifier and Type	Method	Description
static void	AutoscalerFlinkMetrics.initRecommendedParallelism(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics)
static void	AutoscalerFlinkMetrics.resetRecommendedParallelism(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics)

Uses of EvaluatedScalingMetric in org.apache.flink.autoscaler.utils

Method parameters in org.apache.flink.autoscaler.utils with type arguments of type EvaluatedScalingMetric

Modifier and Type	Method	Description
static int	ResourceCheckUtils.estimateNumTaskSlotsAfterRescale(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> vertexMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, int numTaskSlotsUsed)
static double	AutoScalerUtils.getTargetProcessingCapacity(java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, org.apache.flink.configuration.Configuration conf, double targetUtilization, boolean withRestart, java.time.Duration restartTime)