pyflink.datastream.connectors.RollingPolicy#
- class RollingPolicy(j_rolling_policy)[source]#
The policy based on which a Bucket in the FileSink rolls its currently open part file and opens a new one.
Methods
default_rolling_policy
([part_size, ...])Returns the default implementation of the RollingPolicy.
on_checkpoint_rolling_policy
()Returns a RollingPolicy which rolls (ONLY) on every checkpoint.