pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpointing_mode#

CheckpointConfig.set_checkpointing_mode(checkpointing_mode: pyflink.datastream.checkpointing_mode.CheckpointingMode) → pyflink.datastream.checkpoint_config.CheckpointConfig[source]#

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.