CheckpointConfiguration class

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

CheckpointConfiguration({required ConfigurationType configurationType, int? checkpointInterval, bool? checkpointingEnabled, int? minPauseBetweenCheckpoints})

Properties

checkpointingEnabled → bool?

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

final

checkpointInterval → int?

Describes the interval in milliseconds between checkpoint operations.

final

configurationType → ConfigurationType

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.

final

hashCode → int

The hash code for this object.

no setter, inherited

minPauseBetweenCheckpoints → int?

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.

final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toJson() → Map<String, dynamic>

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited