pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpointing_mode

CheckpointConfig.set_checkpointing_mode(checkpointing_mode: CheckpointingMode) → CheckpointConfig

Sets the checkpointing mode (CheckpointingMode.EXACTLY_ONCE vs. CheckpointingMode.AT_LEAST_ONCE).

Example:

>>> config.set_checkpointing_mode(CheckpointingMode.AT_LEAST_ONCE)

Parameters:

checkpointing_mode – The CheckpointingMode.