RescaleApiScalingRealizer (Flink Kubernetes: 1.9-SNAPSHOT API)

java.lang.Object
- org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer<KEY,Context>

All Implemented Interfaces:

ScalingRealizer<KEY,Context>
```
public class RescaleApiScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>
extends java.lang.Object
implements ScalingRealizer<KEY,Context>
```
A ScalingRealizer which uses the Rescale API to apply parallelism changes.
Note: This is based on code copied from the operator, and they don't depend on each other, so some code is duplicated.

Constructor Summary

Constructors
Constructor Description

RescaleApiScalingRealizer(AutoScalerEventHandler<KEY,Context> eventHandler)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`realizeConfigOverrides(Context context, ConfigChanges configChanges)`	Updates the TaskManager memory configuration.
`void`	`realizeParallelismOverrides(Context context, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)`	Update job's parallelism to parallelismOverrides.

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

- Constructor Detail
  - RescaleApiScalingRealizer
```
public RescaleApiScalingRealizer(AutoScalerEventHandler<KEY,Context> eventHandler)
```
- Method Detail
  - realizeParallelismOverrides
```
public void realizeParallelismOverrides(Context context,
                                        java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
```
    Description copied from interface: ScalingRealizer
    
    Update job's parallelism to parallelismOverrides.
    
    Specified by:
    
    realizeParallelismOverrides in interface ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>
  - realizeConfigOverrides
```
public void realizeConfigOverrides(Context context,
                                   ConfigChanges configChanges)
```
    Description copied from interface: ScalingRealizer
    
    Updates the TaskManager memory configuration.
    
    Specified by:
    
    realizeConfigOverrides in interface ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>