org.apache.flink.streaming.api.functions.sink.filesystem

Class Bucket<IN,BucketID>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.filesystem.Bucket<IN,BucketID>

@Internal
public class Bucket<IN,BucketID>
extends Object

A bucket is the directory organization of the output of the StreamingFileSink.

For each incoming element in the StreamingFileSink, the user-specified BucketAssigner is queried to see in which bucket this element should be written to.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait