Uses of Interface
org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy

Packages that use RollingPolicy

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

Uses of RollingPolicy in org.apache.flink.streaming.api.functions.sink.filesystem

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type RollingPolicy

Modifier and Type	Method and Description
<ID> StreamingFileSink.RowFormatBuilder<IN,ID>	StreamingFileSink.RowFormatBuilder.withBucketAssignerAndPolicy(BucketAssigner<IN,ID> assigner, RollingPolicy<IN,ID> policy)
StreamingFileSink.RowFormatBuilder<IN,BucketID>	StreamingFileSink.RowFormatBuilder.withRollingPolicy(RollingPolicy<IN,BucketID> policy)

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

Classes in org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies that implement RollingPolicy

Modifier and Type	Class and Description
class	DefaultRollingPolicy<IN,BucketID> The default implementation of the RollingPolicy.
class	OnCheckpointRollingPolicy<IN,BucketID> A RollingPolicy which rolls on every checkpoint.