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 Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void realize​(Context context, java.util.Map<java.lang.String,​java.lang.String> parallelismOverrides)
      Update job's parallelism to parallelismOverrides.

    • Method Detail

      • realize

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