Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
-
-
Uses of ScalingMetric in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return types with arguments of type ScalingMetric Modifier and Type Method Description java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>>
ScalingMetricEvaluator. evaluate(org.apache.flink.configuration.Configuration conf, CollectedMetrics collectedMetrics)
protected java.util.Map<io.javaoperatorsdk.operator.processing.event.ResourceID,java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>>>
ScalingMetricCollector. getHistories()
java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>>
AutoScalerInfo. getMetricHistory()
Method parameters in org.apache.flink.kubernetes.operator.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)
int
JobVertexScaler. computeScaleTargetParallelism(AbstractFlinkResource<?,?> resource, org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, java.util.SortedMap<java.time.Instant,ScalingSummary> history)
boolean
ScalingExecutor. scaleResource(AbstractFlinkResource<?,?> resource, AutoScalerInfo scalingInformation, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>> evaluatedMetrics)
void
AutoScalerInfo. updateMetricHistory(java.time.Instant jobUpdateTs, java.util.SortedMap<java.time.Instant,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,java.lang.Double>>> history)
Constructor parameters in org.apache.flink.kubernetes.operator.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.kubernetes.operator.autoscaler.metrics
Methods in org.apache.flink.kubernetes.operator.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. -
Uses of ScalingMetric in org.apache.flink.kubernetes.operator.autoscaler.utils
Method parameters in org.apache.flink.kubernetes.operator.autoscaler.utils with type arguments of type ScalingMetric Modifier and Type Method Description static double
AutoScalerUtils. getTargetProcessingCapacity(java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, org.apache.flink.configuration.Configuration conf, double targetUtilization, boolean withRestart)
-