Class CfnApplication.ParallelismConfigurationProperty
Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.
Inheritance
Namespace: Amazon.CDK.AWS.KinesisAnalyticsV2
Assembly: Amazon.CDK.AWS.KinesisAnalyticsV2.dll
Syntax (csharp)
public class ParallelismConfigurationProperty : Object, CfnApplication.IParallelismConfigurationProperty
Syntax (vb)
Public Class ParallelismConfigurationProperty
Inherits Object
Implements CfnApplication.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.KinesisAnalyticsV2;
var parallelismConfigurationProperty = new ParallelismConfigurationProperty {
ConfigurationType = "configurationType",
// the properties below are optional
AutoScalingEnabled = false,
Parallelism = 123,
ParallelismPerKpu = 123
};
Synopsis
Constructors
ParallelismConfigurationProperty() |
Properties
AutoScalingEnabled | Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput. |
ConfigurationType | Describes whether the application uses the default parallelism for the Kinesis Data Analytics service. |
Parallelism | Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform. |
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. |
Constructors
ParallelismConfigurationProperty()
public ParallelismConfigurationProperty()
Properties
AutoScalingEnabled
Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
public object AutoScalingEnabled { get; set; }
Property Value
System.Object
Remarks
ConfigurationType
Describes whether the application uses the default parallelism for the Kinesis Data Analytics service.
public string ConfigurationType { get; set; }
Property Value
System.String
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.Nullable<System.Double>
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.Nullable<System.Double>