pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpointing_mode#

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

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

Example:

>>> config.set_checkpointing_mode(CheckpointingMode.AT_LEAST_ONCE)