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

    • Method Detail

      • scale

        void scale​(Context context)
            throws java.lang.Exception
        Compute and apply new parallelism overrides for the provided job context.
        Parameters:
        context - Job context.
        Throws:
        java.lang.Exception
      • cleanup

        void cleanup​(KEY jobKey)
        Called when the job is deleted.
        Parameters:
        jobKey - Job key.