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 theStreamingFileSink
.For each incoming element in the
StreamingFileSink
, the user-specifiedBucketAssigner
is queried to see in which bucket this element should be written to.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BucketID
getBucketId()
Path
getBucketPath()
long
getPartCounter()
-