ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfiguration

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

Constructors

constructor(checkpointInterval: Int? = null, checkpointingEnabled: Boolean? = null, configurationType: String, minPauseBetweenCheckpoints: Int? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

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

Link copied to clipboard
val checkpointInterval: Int? = null

Describes the interval in milliseconds between checkpoint operations.

Link copied to clipboard

Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:

Link copied to clipboard

Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.