/AWS1/CL_KN2PARALLELISMCONF

Describes parameters for how a Managed Service for Apache Flink application executes multiple tasks simultaneously. For more information about parallelism, see Parallel Execution in the Apache Flink Documentation.

CONSTRUCTOR

IMPORTING

Required arguments:

iv_configurationtype TYPE /AWS1/KN2CONFIGURATIONTYPE /AWS1/KN2CONFIGURATIONTYPE

Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM in order to change your application's AutoScalingEnabled, Parallelism, or ParallelismPerKPU properties.

Optional arguments:

iv_parallelism TYPE /AWS1/KN2PARALLELISM /AWS1/KN2PARALLELISM

Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink increases the CurrentParallelism value in response to application load. The service can increase the CurrentParallelism value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 64 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.

iv_parallelismperkpu TYPE /AWS1/KN2PARALLELISMPERKPU /AWS1/KN2PARALLELISMPERKPU

Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.

iv_autoscalingenabled TYPE /AWS1/KN2BOOLEANOBJECT /AWS1/KN2BOOLEANOBJECT

Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

---

Queryable Attributes

ConfigurationType

Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. You must set this property to CUSTOM in order to change your application's AutoScalingEnabled, Parallelism, or ParallelismPerKPU properties.

Accessible with the following methods

Method	Description
GET_CONFIGURATIONTYPE()	Getter for CONFIGURATIONTYPE, with configurable default
ASK_CONFIGURATIONTYPE()	Getter for CONFIGURATIONTYPE w/ exceptions if field has no v
HAS_CONFIGURATIONTYPE()	Determine if CONFIGURATIONTYPE has a value

Parallelism

Describes the initial number of parallel tasks that a Managed Service for Apache Flink application can perform. If AutoScalingEnabled is set to True, Managed Service for Apache Flink increases the CurrentParallelism value in response to application load. The service can increase the CurrentParallelism value up to the maximum parallelism, which is ParalellismPerKPU times the maximum KPUs for the application. The maximum KPUs for an application is 64 by default, and can be increased by requesting a limit increase. If application load is reduced, the service can reduce the CurrentParallelism value down to the Parallelism setting.

Accessible with the following methods

Method	Description
GET_PARALLELISM()	Getter for PARALLELISM, with configurable default
ASK_PARALLELISM()	Getter for PARALLELISM w/ exceptions if field has no value
HAS_PARALLELISM()	Determine if PARALLELISM has a value

ParallelismPerKPU

Describes the number of parallel tasks that a Managed Service for Apache Flink application can perform per Kinesis Processing Unit (KPU) used by the application. For more information about KPUs, see Amazon Managed Service for Apache Flink Pricing.

Accessible with the following methods

Method	Description
GET_PARALLELISMPERKPU()	Getter for PARALLELISMPERKPU, with configurable default
ASK_PARALLELISMPERKPU()	Getter for PARALLELISMPERKPU w/ exceptions if field has no v
HAS_PARALLELISMPERKPU()	Determine if PARALLELISMPERKPU has a value

AutoScalingEnabled

Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.

Accessible with the following methods

Method	Description
GET_AUTOSCALINGENABLED()	Getter for AUTOSCALINGENABLED, with configurable default
ASK_AUTOSCALINGENABLED()	Getter for AUTOSCALINGENABLED w/ exceptions if field has no
HAS_AUTOSCALINGENABLED()	Determine if AUTOSCALINGENABLED has a value