Package org.apache.flink.autoscaler.utils

Class ResourceCheckUtils

java.lang.Object

org.apache.flink.autoscaler.utils.ResourceCheckUtils

public class ResourceCheckUtils
extends java.lang.Object

Utils methods for resource checks.

Constructor Summary

Constructors

Constructor	Description
ResourceCheckUtils()

Method Summary

Modifier and Type	Method	Description
static java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer>	computeNewParallelisms(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> vertexMetrics)
static int	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)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceCheckUtils

public ResourceCheckUtils()

Method Detail

estimateNumTaskSlotsAfterRescale

public static int 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)

computeNewParallelisms

public static java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> computeNewParallelisms(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries,
                                                                                                                          java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> vertexMetrics)