Class CfnApplicationV2.ParallelismConfigurationProperty
Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.
Inheritance
Namespace: Amazon.CDK.AWS.KinesisAnalytics
Assembly: Amazon.CDK.Lib.dll
Syntax (csharp)
public class ParallelismConfigurationProperty : Object, CfnApplicationV2.IParallelismConfigurationProperty
Syntax (vb)
Public Class ParallelismConfigurationProperty
Inherits Object
Implements CfnApplicationV2.IParallelismConfigurationProperty
Remarks
For more information about parallelism, see Parallel Execution in the Apache Flink Documentation .
ExampleMetadata: fixture=_generated
Examples
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
using Amazon.CDK.AWS.KinesisAnalytics;
var parallelismConfigurationProperty = new ParallelismConfigurationProperty {
ConfigurationType = "configurationType",
// the properties below are optional
AutoScalingEnabled = false,
Parallelism = 123,
ParallelismPerKpu = 123
};
Synopsis
Constructors
Parallelism |
Properties
Auto |
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput. |
Configuration |
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service. |
Parallelism | Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform. |
Parallelism |
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. |
Constructors
ParallelismConfigurationProperty()
public ParallelismConfigurationProperty()
Properties
AutoScalingEnabled
Describes whether the Managed Service for Apache Flink service can increase the parallelism of the application in response to increased throughput.
public object AutoScalingEnabled { get; set; }
Property Value
System.
Remarks
ConfigurationType
Describes whether the application uses the default parallelism for the Managed Service for Apache Flink service.
public string ConfigurationType { get; set; }
Property Value
System.
Remarks
You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
Parallelism
Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform.
public Nullable<double> Parallelism { get; set; }
Property Value
System.
Remarks
The Kinesis Data Analytics service can increase this number automatically if ParallelismConfiguration:AutoScalingEnabled is set to true
.
ParallelismPerKpu
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.
public Nullable<double> ParallelismPerKpu { get; set; }
Property Value
System.