pyflink.datastream.connectors.file_system.RollingPolicy

class RollingPolicy(j_rolling_policy)

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.