pyflink.datastream.connectors.file_system.DefaultRollingPolicy#
- class DefaultRollingPolicy(j_rolling_policy)[source]#
The default implementation of the RollingPolicy.
This policy rolls a part file if:
there is no open part file,
the current file has reached the maximum bucket size (by default 128MB),
the current file is older than the roll over interval (by default 60 sec), or
the current file has not been written to for more than the allowed inactivityTime (by default 60 sec).
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.