Class 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 Detail

      • getBucketId

        public BucketID getBucketId()
      • getBucketPath

        public Path getBucketPath()
      • getPartCounter

        public long getPartCounter()