interface ParallelismConfigurationProperty
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.KinesisAnalyticsV2.CfnApplication.ParallelismConfigurationProperty |
Java | software.amazon.awscdk.services.kinesisanalyticsv2.CfnApplication.ParallelismConfigurationProperty |
Python | aws_cdk.aws_kinesisanalyticsv2.CfnApplication.ParallelismConfigurationProperty |
TypeScript | @aws-cdk/aws-kinesisanalyticsv2 » CfnApplication » ParallelismConfigurationProperty |
Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.
For more information about parallelism, see Parallel Execution in the Apache Flink Documentation .
Example
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as kinesisanalyticsv2 from '@aws-cdk/aws-kinesisanalyticsv2';
const parallelismConfigurationProperty: kinesisanalyticsv2.CfnApplication.ParallelismConfigurationProperty = {
configurationType: 'configurationType',
// the properties below are optional
autoScalingEnabled: false,
parallelism: 123,
parallelismPerKpu: 123,
};
Properties
Name | Type | Description |
---|---|---|
configuration | string | Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. |
auto | boolean | IResolvable | Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput. |
parallelism? | number | Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform. |
parallelism | number | Describes the number of parallel tasks that a Java-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application. |
configurationType
Type:
string
Describes whether the application uses the default parallelism for the Kinesis Data Analytics service.
You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
autoScalingEnabled?
Type:
boolean |
IResolvable
(optional)
Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
parallelism?
Type:
number
(optional)
Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform.
The Kinesis Data Analytics service can increase this number automatically if ParallelismConfiguration:AutoScalingEnabled is set to true
.
parallelismPerKpu?
Type:
number
(optional)
Describes the number of parallel tasks that a Java-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
For more information about KPUs, see Amazon Kinesis Data Analytics Pricing .