public interface Bucketer<T> extends Serializable
BucketingSinkto put emitted elements into rolling files.
BucketingSink can be writing to many buckets at a time, and it is responsible for managing
a set of active buckets. Whenever a new element arrives it will ask the
Bucketer for the bucket
path the element should fall in. The
Bucketer can, for example, determine buckets based on
Pathof a bucket file.
basePath- The base path containing all the buckets.
element- The current element being processed.
Pathof the bucket which the provided element should fall in. This should include the
basePathand also the
subtaskIndexto avoid clashes with parallel sinks.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.