Interface RescalingController
-
- All Known Implementing Classes:
EnforceMinimalIncreaseRescalingController
@Internal public interface RescalingControllerSimple policy for controlling the scale up/down behavior of theAdaptiveScheduler.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanshouldRescale(VertexParallelism currentParallelism, VertexParallelism newParallelism)This method gets called whenever new resources orresource requirementsare available and the scheduler needs to design whether to rescale or not.
-
-
-
Method Detail
-
shouldRescale
boolean shouldRescale(VertexParallelism currentParallelism, VertexParallelism newParallelism)
This method gets called whenever new resources orresource requirementsare 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.
-
-