pyflink.datastream.connectors.file_system.OnCheckpointRollingPolicy#

class OnCheckpointRollingPolicy(j_rolling_policy)[source]#

A RollingPolicy which rolls (ONLY) on every checkpoint.

Methods

`default_rolling_policy`([part_size, ...])	Returns the default implementation of the RollingPolicy.
`get_java_object`()
`on_checkpoint_rolling_policy`()	Returns a RollingPolicy which rolls (ONLY) on every checkpoint.