Package org.apache.flink.autoscaler.realizer

Interface ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>

Type Parameters:

KEY - The job key.

Context - Instance of JobAutoScalerContext.

All Known Implementing Classes:

KubernetesScalingRealizer, RescaleApiScalingRealizer

@Experimental
public interface ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>

The Scaling Realizer is responsible for applying scaling actions, i.e. actually rescaling the jobs.

Method Summary

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.

Method Detail

realizeParallelismOverrides

void realizeParallelismOverrides(Context context,
                                 java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
                          throws java.lang.Exception

Update job's parallelism to parallelismOverrides.

Throws:

java.lang.Exception - Error during realize parallelism overrides.

realizeConfigOverrides

void realizeConfigOverrides(Context context,
                            ConfigChanges configChanges)
                     throws java.lang.Exception

Updates the TaskManager memory configuration.

Throws:

java.lang.Exception - Error during realize config overrides.