Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Packages that use ScalingMetric

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

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, CollectedMetricHistory collectedMetrics)

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, boolean processingBacklog)
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, io.fabric8.kubernetes.client.KubernetesClient client)
void	AutoscalerFlinkMetrics.registerScalingMetrics(java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> jobVertices, java.util.function.Supplier<java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<ScalingMetric,EvaluatedScalingMetric>>> metricsSupplier)
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, io.fabric8.kubernetes.client.KubernetesClient client)

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)