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-specifiedBucketAssigneris 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 BucketIDgetBucketId()org.apache.flink.core.fs.PathgetBucketPath()longgetPartCounter()
-
-
-
Method Detail
-
getBucketId
public BucketID getBucketId()
-
getBucketPath
public org.apache.flink.core.fs.Path getBucketPath()
-
getPartCounter
public long getPartCounter()
-
-