Class ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration
- java.lang.Object
-
- com.pulumi.aws.kinesisanalyticsv2.outputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration
-
public final class ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration.Builder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Optional<java.lang.Boolean>autoScalingEnabled()static ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration.Builderbuilder()static ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration.Builderbuilder(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration defaults)java.lang.StringconfigurationType()java.util.Optional<java.lang.Integer>parallelism()java.util.Optional<java.lang.Integer>parallelismPerKpu()
-
-
-
Method Detail
-
autoScalingEnabled
public java.util.Optional<java.lang.Boolean> autoScalingEnabled()
- Returns:
- Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
-
configurationType
public java.lang.String configurationType()
- Returns:
- Whether the application uses the default parallelism for the Kinesis Data Analytics service. Valid values: `CUSTOM`, `DEFAULT`. Set this attribute to `CUSTOM` in order for any specified `autoScalingEnabled`, `parallelism`, or `parallelismPerKpu` attribute values to be effective.
-
parallelism
public java.util.Optional<java.lang.Integer> parallelism()
- Returns:
- Initial number of parallel tasks that a Flink-based application can perform.
-
parallelismPerKpu
public java.util.Optional<java.lang.Integer> parallelismPerKpu()
- Returns:
- Number of parallel tasks that a Flink-based application can perform per Kinesis Processing Unit (KPU) used by the application.
-
builder
public static ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfiguration.Builder builder()
-
-