pyflink.datastream.connectors.file_system.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.
`get_java_object`()
`on_checkpoint_rolling_policy`()	Returns a RollingPolicy which rolls (ONLY) on every checkpoint.