Uses of Class
org.apache.flink.autoscaler.metrics.ScalingMetric
-
Packages that use ScalingMetric Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.metrics org.apache.flink.autoscaler.utils -
-
Uses of ScalingMetric in org.apache.flink.autoscaler
Methods in org.apache.flink.autoscaler that return types with arguments of type ScalingMetric Modifier and Type Method Description protected static java.util.Map<ScalingMetric,EvaluatedScalingMetric>
ScalingMetricEvaluator. evaluateGlobalMetrics(java.util.SortedMap<java.time.Instant,CollectedMetrics> metricHistory)
Methods in org.apache.flink.autoscaler with parameters of type ScalingMetric Modifier and Type Method Description static double
ScalingMetricEvaluator. getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
static double
ScalingMetricEvaluator. getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, int minElements)
static double
ScalingMetricEvaluator. getRate(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
Compute per second rate for the given accumulated metric over the metric window.Method parameters in org.apache.flink.autoscaler with type arguments of type ScalingMetric 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 ScalingMetric Constructor Description ScalingSummary(int currentParallelism, int newParallelism, java.util.Map<ScalingMetric,EvaluatedScalingMetric> metrics)
-
Uses of ScalingMetric in org.apache.flink.autoscaler.metrics
Fields in org.apache.flink.autoscaler.metrics with type parameters of type ScalingMetric Modifier and Type Field Description static java.util.Set<ScalingMetric>
ScalingMetric. REPORTED_VERTEX_METRICS
List ofScalingMetric
s to be reported as per vertex Flink metrics.Methods in org.apache.flink.autoscaler.metrics that return ScalingMetric Modifier and Type Method Description static ScalingMetric
ScalingMetric. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static ScalingMetric[]
ScalingMetric. values()
Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.autoscaler.metrics that return types with arguments of type ScalingMetric Modifier and Type Method Description static java.util.Map<ScalingMetric,java.lang.Double>
ScalingMetrics. computeGlobalMetrics(java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.Metric> collectedJmMetrics, java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> collectedTmMetrics, org.apache.flink.configuration.Configuration conf)
Method parameters in org.apache.flink.autoscaler.metrics with type arguments of type ScalingMetric 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 ScalingMetric in org.apache.flink.autoscaler.utils
Method parameters in org.apache.flink.autoscaler.utils with type arguments of type ScalingMetric 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)
-