Package org.apache.flink.autoscaler.realizer

Interface ScalingRealizer<KEY,​Context extends JobAutoScalerContext<KEY>>

  • Type Parameters:
    KEY - The job key.
    Context - Instance of JobAutoScalerContext.
    All Known Implementing Classes:
    KubernetesScalingRealizer, RescaleApiScalingRealizer
    @Experimental
public interface ScalingRealizer<KEY,​Context extends JobAutoScalerContext<KEY>>
    The Scaling Realizer is responsible for applying scaling actions, i.e. actually rescaling the jobs.

    • Method Detail

      • realizeParallelismOverrides

        void realizeParallelismOverrides​(Context context,
                                 java.util.Map<java.lang.String,​java.lang.String> parallelismOverrides)
        Update job's parallelism to parallelismOverrides.

      • realizeConfigOverrides

        void realizeConfigOverrides​(Context context,
                            ConfigChanges configChanges)
        Updates the TaskManager memory configuration.