pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpoint_storage_dir#
- CheckpointConfig.set_checkpoint_storage_dir(checkpoint_path: str) pyflink.datastream.checkpoint_config.CheckpointConfig [source]#
Configures the application to write out checkpoint snapshots to the configured directory. See FileSystemCheckpointStorage for more details on checkpointing to a file system.