pulumi-aws-native-kotlin/com.pulumi.awsnative.kinesisanalyticsv2.kotlin.outputs/ApplicationCheckpointConfiguration

ApplicationCheckpointConfiguration

data class ApplicationCheckpointConfiguration(val checkpointInterval: Int? = null, val checkpointingEnabled: Boolean? = null, val configurationType: ApplicationCheckpointConfigurationConfigurationType, val minPauseBetweenCheckpoints: Int? = null)

Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.

Constructors

fun ApplicationCheckpointConfiguration(checkpointInterval: Int? = null, checkpointingEnabled: Boolean? = null, configurationType: ApplicationCheckpointConfigurationConfigurationType, minPauseBetweenCheckpoints: Int? = null)

Types

Companion

object Companion

Properties

checkpointingEnabled

val checkpointingEnabled: Boolean? = null

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

checkpointInterval

val checkpointInterval: Int? = null

Describes the interval in milliseconds between checkpoint operations.

configurationType

val configurationType: ApplicationCheckpointConfigurationConfigurationType

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

minPauseBetweenCheckpoints

val minPauseBetweenCheckpoints: Int? = null

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.