Uses of Class
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder

Packages that use DefaultRollingPolicy.PolicyBuilder

Package	Description
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies

Uses of DefaultRollingPolicy.PolicyBuilder in org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies

Methods in org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies that return DefaultRollingPolicy.PolicyBuilder

Modifier and Type	Method and Description
static DefaultRollingPolicy.PolicyBuilder	DefaultRollingPolicy.builder() Creates a new DefaultRollingPolicy.PolicyBuilder that is used to configure and build an instance of DefaultRollingPolicy.
static DefaultRollingPolicy.PolicyBuilder	DefaultRollingPolicy.create() Deprecated.
DefaultRollingPolicy.PolicyBuilder	DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(long interval) Sets the interval of allowed inactivity after which a part file will have to roll.
DefaultRollingPolicy.PolicyBuilder	DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(long size) Sets the part size above which a part file will have to roll.
DefaultRollingPolicy.PolicyBuilder	DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(long interval) Sets the max time a part file can stay open before having to roll.