public static interface CfnApplicationV2.ParallelismConfigurationProperty
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 software.amazon.awscdk.services.kinesisanalytics.*; ParallelismConfigurationProperty parallelismConfigurationProperty = ParallelismConfigurationProperty.builder() .configurationType("configurationType") // the properties below are optional .autoScalingEnabled(false) .parallelism(123) .parallelismPerKpu(123) .build();
Modifier and Type | Interface and Description |
---|---|
static class |
CfnApplicationV2.ParallelismConfigurationProperty.Builder
A builder for
CfnApplicationV2.ParallelismConfigurationProperty |
static class |
CfnApplicationV2.ParallelismConfigurationProperty.Jsii$Proxy
An implementation for
CfnApplicationV2.ParallelismConfigurationProperty |
Modifier and Type | Method and Description |
---|---|
static CfnApplicationV2.ParallelismConfigurationProperty.Builder |
builder() |
default java.lang.Object |
getAutoScalingEnabled()
Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
|
java.lang.String |
getConfigurationType()
Describes whether the application uses the default parallelism for the Kinesis Data Analytics service.
|
default java.lang.Number |
getParallelism()
Describes the initial number of parallel tasks that a Java-based Kinesis Data Analytics application can perform.
|
default java.lang.Number |
getParallelismPerKpu()
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.
|
java.lang.String getConfigurationType()
You must set this property to CUSTOM
in order to change your application's AutoScalingEnabled
, Parallelism
, or ParallelismPerKPU
properties.
default java.lang.Object getAutoScalingEnabled()
default java.lang.Number getParallelism()
The Kinesis Data Analytics service can increase this number automatically if ParallelismConfiguration:AutoScalingEnabled is set to true
.
default java.lang.Number getParallelismPerKpu()
For more information about KPUs, see Amazon Kinesis Data Analytics Pricing .
static CfnApplicationV2.ParallelismConfigurationProperty.Builder builder()