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

Class KubernetesScalingRealizer

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer

All Implemented Interfaces:

ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>

public class KubernetesScalingRealizer
extends java.lang.Object
implements ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>

The Kubernetes implementation for applying parallelism overrides.

Constructor Summary

Constructors

Constructor	Description
KubernetesScalingRealizer()

Method Summary

Modifier and Type	Method	Description
void	realizeConfigOverrides(KubernetesJobAutoScalerContext context, ConfigChanges configChanges)	Updates the TaskManager memory configuration.
void	realizeParallelismOverrides(KubernetesJobAutoScalerContext context, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)	Update job's parallelism to parallelismOverrides.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesScalingRealizer

public KubernetesScalingRealizer()

Method Detail

realizeParallelismOverrides

public void realizeParallelismOverrides(KubernetesJobAutoScalerContext context,
                                        java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)

Description copied from interface: ScalingRealizer

Update job's parallelism to parallelismOverrides.

Specified by:

realizeParallelismOverrides in interface ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>

realizeConfigOverrides

public void realizeConfigOverrides(KubernetesJobAutoScalerContext context,
                                   ConfigChanges configChanges)

Description copied from interface: ScalingRealizer

Updates the TaskManager memory configuration.

Specified by:

realizeConfigOverrides in interface ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>