KubernetesScalingRealizer (Flink Kubernetes: 1.7-SNAPSHOT API)

java.lang.Object
- org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer

All Implemented Interfaces:

ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
```
public class KubernetesScalingRealizer
extends java.lang.Object
implements ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>
```
The Kubernetes implementation for applying parallelism overrides.

Constructor Summary

Constructors
Constructor Description

KubernetesScalingRealizer()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`realize(KubernetesJobAutoScalerContext 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
  - KubernetesScalingRealizer
```
public KubernetesScalingRealizer()
```
- Method Detail
  - realize
```
public void realize(KubernetesJobAutoScalerContext context,
                    java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
```
    Description copied from interface: ScalingRealizer
    
    Update job's parallelism to parallelismOverrides.
    
    Specified by:
    
    realize in interface ScalingRealizer<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>