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.