Package software.amazon.awscdk.services.kinesisanalytics

Class CfnApplicationV2.CheckpointConfigurationProperty.Builder

java.lang.Object

software.amazon.awscdk.services.kinesisanalytics.CfnApplicationV2.CheckpointConfigurationProperty.Builder

All Implemented Interfaces:

software.amazon.jsii.Builder<CfnApplicationV2.CheckpointConfigurationProperty>

Enclosing interface:

CfnApplicationV2.CheckpointConfigurationProperty

@Stability(Stable)
public static final class CfnApplicationV2.CheckpointConfigurationProperty.Builder
extends Object
implements software.amazon.jsii.Builder<CfnApplicationV2.CheckpointConfigurationProperty>

A builder for CfnApplicationV2.CheckpointConfigurationProperty

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
CfnApplicationV2.CheckpointConfigurationProperty	build()	Builds the configured instance.
CfnApplicationV2.CheckpointConfigurationProperty.Builder	checkpointingEnabled(Boolean checkpointingEnabled)	Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointingEnabled()
CfnApplicationV2.CheckpointConfigurationProperty.Builder	checkpointingEnabled(IResolvable checkpointingEnabled)	Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointingEnabled()
CfnApplicationV2.CheckpointConfigurationProperty.Builder	checkpointInterval(Number checkpointInterval)	Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointInterval()
CfnApplicationV2.CheckpointConfigurationProperty.Builder	configurationType(String configurationType)	Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getConfigurationType()
CfnApplicationV2.CheckpointConfigurationProperty.Builder	minPauseBetweenCheckpoints(Number minPauseBetweenCheckpoints)	Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getMinPauseBetweenCheckpoints()

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

configurationType

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty.Builder configurationType(String configurationType)

Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getConfigurationType()

Parameters:

configurationType - Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. This parameter is required. You must set this property to CUSTOM in order to set the CheckpointingEnabled , CheckpointInterval , or MinPauseBetweenCheckpoints parameters.

If this value is set to DEFAULT , the application will use the following values, even if they are set to other values using APIs or application code:

• CheckpointingEnabled: true
• CheckpointInterval: 60000
• MinPauseBetweenCheckpoints: 5000

Returns:

this

checkpointingEnabled

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty.Builder checkpointingEnabled(Boolean checkpointingEnabled)

Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointingEnabled()

Parameters:

checkpointingEnabled - Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.

If CheckpointConfiguration.ConfigurationType is DEFAULT , the application will use a CheckpointingEnabled value of true , even if this value is set to another value using this API or in application code.

Returns:

this

checkpointingEnabled

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty.Builder checkpointingEnabled(IResolvable checkpointingEnabled)

Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointingEnabled()

Parameters:

checkpointingEnabled - Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.

If CheckpointConfiguration.ConfigurationType is DEFAULT , the application will use a CheckpointingEnabled value of true , even if this value is set to another value using this API or in application code.

Returns:

this

checkpointInterval

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty.Builder checkpointInterval(Number checkpointInterval)

Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getCheckpointInterval()

Parameters:

checkpointInterval - Describes the interval in milliseconds between checkpoint operations.

If CheckpointConfiguration.ConfigurationType is DEFAULT , the application will use a CheckpointInterval value of 60000, even if this value is set to another value using this API or in application code.

Returns:

this

minPauseBetweenCheckpoints

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty.Builder minPauseBetweenCheckpoints(Number minPauseBetweenCheckpoints)

Sets the value of CfnApplicationV2.CheckpointConfigurationProperty.getMinPauseBetweenCheckpoints()

Parameters:

minPauseBetweenCheckpoints - Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start. If a checkpoint operation takes longer than the CheckpointInterval , the application otherwise performs continual checkpoint operations. For more information, see Tuning Checkpointing in the Apache Flink Documentation .

If CheckpointConfiguration.ConfigurationType is DEFAULT , the application will use a MinPauseBetweenCheckpoints value of 5000, even if this value is set using this API or in application code.

Returns:

this

build

@Stability(Stable)
public CfnApplicationV2.CheckpointConfigurationProperty build()

Builds the configured instance.

Specified by:

build in interface software.amazon.jsii.Builder<CfnApplicationV2.CheckpointConfigurationProperty>

Returns:

a new instance of CfnApplicationV2.CheckpointConfigurationProperty

Throws:

NullPointerException - if any required attribute was not provided