org.apache.flink.runtime.scheduler.adaptive.scalingpolicy

Class ReactiveScaleUpController

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.scalingpolicy.ReactiveScaleUpController

All Implemented Interfaces:

ScaleUpController

public class ReactiveScaleUpController
extends Object
implements ScaleUpController

Simple scaling policy for a reactive mode. The user can configure a minimum cumulative parallelism increase to allow a scale up.

Constructor Summary

Constructors

Constructor and Description
ReactiveScaleUpController(Configuration configuration)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReactiveScaleUpController

public ReactiveScaleUpController(Configuration configuration)

Method Detail

canScaleUp

public boolean canScaleUp(int currentCumulativeParallelism,
                          int newCumulativeParallelism)

Description copied from interface: ScaleUpController

This method gets called whenever new resources are available to the scheduler to scale up.

Specified by:

canScaleUp in interface ScaleUpController

Parameters:

currentCumulativeParallelism - Cumulative parallelism of the currently running job graph.

newCumulativeParallelism - Potential new cumulative parallelism with the additional resources.

Returns:

true if the policy decided to scale up based on the provided information.