Class KubernetesScalingRealizer

  • All Implemented Interfaces:
    org.apache.flink.autoscaler.realizer.ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,​KubernetesJobAutoScalerContext>

    public class KubernetesScalingRealizer
    extends java.lang.Object
    implements org.apache.flink.autoscaler.realizer.ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,​KubernetesJobAutoScalerContext>
    The Kubernetes implementation for applying parallelism overrides.
    • Constructor Detail

      • KubernetesScalingRealizer

        public KubernetesScalingRealizer()
    • Method Detail

      • realize

        public void realize​(KubernetesJobAutoScalerContext context,
                            java.util.Map<java.lang.String,​java.lang.String> parallelismOverrides)
        Specified by:
        realize in interface org.apache.flink.autoscaler.realizer.ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,​KubernetesJobAutoScalerContext>