@Internal public interface ScaleUpController
AdaptiveScheduler
.Modifier and Type | Method and Description |
---|---|
boolean |
canScaleUp(int currentCumulativeParallelism,
int newCumulativeParallelism)
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–2022 The Apache Software Foundation. All rights reserved.