pyflink.datastream.connectors.file_system.DefaultRollingPolicy

class DefaultRollingPolicy(j_rolling_policy)

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.