Package com.pulumi.aws.kinesisanalyticsv2.inputs

Class ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder

java.lang.Object

com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder

Enclosing class:

ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs

public static final class ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs defaults)

Method Summary

Modifier and Type	Method	Description
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	autoScalingEnabled(com.pulumi.core.Output<java.lang.Boolean> autoScalingEnabled)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	autoScalingEnabled(java.lang.Boolean autoScalingEnabled)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs	build()
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	configurationType(com.pulumi.core.Output<java.lang.String> configurationType)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	configurationType(java.lang.String configurationType)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	parallelism(com.pulumi.core.Output<java.lang.Integer> parallelism)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	parallelism(java.lang.Integer parallelism)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	parallelismPerKpu(com.pulumi.core.Output<java.lang.Integer> parallelismPerKpu)
ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder	parallelismPerKpu(java.lang.Integer parallelismPerKpu)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Builder

public Builder(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs defaults)

Method Detail

autoScalingEnabled

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder autoScalingEnabled(@Nullable
                                                                                                                               com.pulumi.core.Output<java.lang.Boolean> autoScalingEnabled)

Parameters:

autoScalingEnabled - Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.

Returns:

builder

autoScalingEnabled

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder autoScalingEnabled(java.lang.Boolean autoScalingEnabled)

Parameters:

autoScalingEnabled - Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.

Returns:

builder

configurationType

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder configurationType(com.pulumi.core.Output<java.lang.String> configurationType)

Parameters:

configurationType - 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.

Returns:

builder

configurationType

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder configurationType(java.lang.String configurationType)

Parameters:

configurationType - 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.

Returns:

builder

parallelism

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder parallelism(@Nullable
                                                                                                                        com.pulumi.core.Output<java.lang.Integer> parallelism)

Parameters:

parallelism - Initial number of parallel tasks that a Flink-based application can perform.

Returns:

builder

parallelism

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder parallelism(java.lang.Integer parallelism)

Parameters:

parallelism - Initial number of parallel tasks that a Flink-based application can perform.

Returns:

builder

parallelismPerKpu

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder parallelismPerKpu(@Nullable
                                                                                                                              com.pulumi.core.Output<java.lang.Integer> parallelismPerKpu)

Parameters:

parallelismPerKpu - Number of parallel tasks that a Flink-based application can perform per Kinesis Processing Unit (KPU) used by the application.

Returns:

builder

parallelismPerKpu

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.Builder parallelismPerKpu(java.lang.Integer parallelismPerKpu)

Parameters:

parallelismPerKpu - Number of parallel tasks that a Flink-based application can perform per Kinesis Processing Unit (KPU) used by the application.

Returns:

builder

build

public ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs build()