Interface RescalingController

    • Method Detail

      • shouldRescale

        boolean shouldRescale​(VertexParallelism currentParallelism,
                              VertexParallelism newParallelism)
        This method gets called whenever new resources or resource requirements are available and the scheduler needs to design whether to rescale or not.
        Parameters:
        currentParallelism - parallelism of the currently running job graph.
        newParallelism - Potential new parallelism with the additional resources.
        Returns:
        true if the policy decided to rescale based on the provided information.