@Deprecated 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
for the bucket path the element should fall in. The
Bucketer can, for example, determine
buckets based on system time.
Pathof a bucket file.
clock- The current system time in milliseconds.
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–2021 The Apache Software Foundation. All rights reserved.