Package org.apache.flink.kubernetes.operator.autoscaler

Class ScalingExecutor

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

public class ScalingExecutor
extends java.lang.Object

Class responsible for executing scaling decisions.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<java.util.Map<java.lang.String,java.lang.String>>	PARALLELISM_OVERRIDES
static java.lang.String	SCALING_SUMMARY_ENTRY
static java.lang.String	SCALING_SUMMARY_HEADER_SCALING_DISABLED
static java.lang.String	SCALING_SUMMARY_HEADER_SCALING_ENABLED

Constructor Summary

Constructors

Constructor	Description
ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, JobVertexScaler jobVertexScaler, EventRecorder eventRecorder)
ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
protected static boolean	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)
boolean	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)
protected void	setClock(java.time.Clock clock)

Methods inherited from class java.lang.Object

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

Field Detail

PARALLELISM_OVERRIDES

public static final org.apache.flink.configuration.ConfigOption<java.util.Map<java.lang.String,java.lang.String>> PARALLELISM_OVERRIDES

SCALING_SUMMARY_ENTRY

public static final java.lang.String SCALING_SUMMARY_ENTRY

See Also:

Constant Field Values

SCALING_SUMMARY_HEADER_SCALING_DISABLED

public static final java.lang.String SCALING_SUMMARY_HEADER_SCALING_DISABLED

See Also:

Constant Field Values

SCALING_SUMMARY_HEADER_SCALING_ENABLED

public static final java.lang.String SCALING_SUMMARY_HEADER_SCALING_ENABLED

See Also:

Constant Field Values

Constructor Detail

ScalingExecutor

public ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                       EventRecorder eventRecorder)

ScalingExecutor

public ScalingExecutor(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                       JobVertexScaler jobVertexScaler,
                       EventRecorder eventRecorder)

Method Detail

scaleResource

public boolean 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)

allVerticesWithinUtilizationTarget

protected static boolean 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)

setClock

@VisibleForTesting
protected void setClock(java.time.Clock clock)