public class ReactiveScaleUpController extends Object implements ScaleUpController
|Constructor and Description|
|Modifier and Type||Method and Description|
This method gets called whenever new resources are available to the scheduler to scale up.
public ReactiveScaleUpController(Configuration configuration)
public 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.