@Internal public interface ScaleUpController
|Modifier and Type||Method and Description|
This method gets called whenever new resources are available to the scheduler to scale up.
boolean canScaleUp(int currentCumulativeParallelism, int newCumulativeParallelism)
currentCumulativeParallelism- Cumulative parallelism of the currently running job graph.
newCumulativeParallelism- Potential new cumulative parallelism with the additional resources.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.