pyflink.datastream.connectors.file_system.OnCheckpointRollingPolicy

class OnCheckpointRollingPolicy(j_rolling_policy)

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.