Uses of Class
org.apache.flink.autoscaler.metrics.EvaluatedMetrics
-
Packages that use EvaluatedMetrics Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.metrics org.apache.flink.autoscaler.tuning -
-
Uses of EvaluatedMetrics in org.apache.flink.autoscaler
Methods in org.apache.flink.autoscaler that return EvaluatedMetrics Modifier and Type Method Description EvaluatedMetrics
ScalingMetricEvaluator. evaluate(org.apache.flink.configuration.Configuration conf, CollectedMetricHistory collectedMetrics, java.time.Duration restartTime)
Methods in org.apache.flink.autoscaler with parameters of type EvaluatedMetrics Modifier and Type Method Description boolean
ScalingExecutor. scaleResource(Context context, EvaluatedMetrics evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,ScalingSummary>> scalingHistory, ScalingTracking scalingTracking, java.time.Instant now, JobTopology jobTopology)
protected boolean
ScalingExecutor. scalingWouldExceedMaxResources(org.apache.flink.configuration.Configuration tunedConfig, JobTopology jobTopology, EvaluatedMetrics evaluatedMetrics, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, Context ctx)
-
Uses of EvaluatedMetrics in org.apache.flink.autoscaler.metrics
Method parameters in org.apache.flink.autoscaler.metrics with type arguments of type EvaluatedMetrics Modifier and Type Method Description void
AutoscalerFlinkMetrics. registerScalingMetrics(java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> jobVertices, java.util.function.Supplier<EvaluatedMetrics> metricsSupplier)
-
Uses of EvaluatedMetrics in org.apache.flink.autoscaler.tuning
Methods in org.apache.flink.autoscaler.tuning with parameters of type EvaluatedMetrics Modifier and Type Method Description static org.apache.flink.configuration.MemorySize
MemoryScaling. applyMemoryScaling(org.apache.flink.configuration.MemorySize currentMemorySize, MemoryBudget memoryBudget, JobAutoScalerContext<?> context, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, EvaluatedMetrics evaluatedMetrics)
Scales the amount of memory per TaskManager proportionally to the number of TaskManagers removed/added.static ConfigChanges
MemoryTuning. tuneTaskManagerMemory(JobAutoScalerContext<?> context, EvaluatedMetrics evaluatedMetrics, JobTopology jobTopology, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, AutoScalerEventHandler eventHandler)
Emits a Configuration which contains overrides for the current configuration.
-