Package org.apache.flink.streaming.connectors.fs.bucketing

Interface Summary

Interface	Description
Bucketer<T>	A bucketer is used with a BucketingSink to put emitted elements into rolling files.

Class Summary

Class	Description
BasePathBucketer<T>	A Bucketer that does not perform any bucketing of files.
BucketingSink<T>	Sink that emits its input elements to FileSystem files within buckets.
DateTimeBucketer<T>	A Bucketer that assigns to buckets based on current system time.