EnforceParallelismChangeRescalingController (Flink : Runtime 1.19.3-cp2 API)

java.lang.Object
- org.apache.flink.runtime.scheduler.adaptive.scalingpolicy.EnforceParallelismChangeRescalingController

All Implemented Interfaces:

RescalingController
```
public class EnforceParallelismChangeRescalingController
extends Object
implements RescalingController
```
Simple scaling policy. It just checks that the new parallelism is different (either increase or decrease) from the current parallelism.

Constructor Summary

Constructors
Constructor Description

EnforceParallelismChangeRescalingController()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`shouldRescale(VertexParallelism currentParallelism, VertexParallelism newParallelism)`	This method gets called whenever new resources or `resource requirements` are available and the scheduler needs to design whether to rescale or not.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - EnforceParallelismChangeRescalingController
```
public EnforceParallelismChangeRescalingController()
```
- Method Detail
  - shouldRescale
```
public boolean shouldRescale(VertexParallelism currentParallelism,
                             VertexParallelism newParallelism)
```
    Description copied from interface: RescalingController
    
    This method gets called whenever new resources or resource requirements are available and the scheduler needs to design whether to rescale or not.
    
    Specified by:
    
    shouldRescale in interface RescalingController
    
    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.