public static class BucketingSinkTestProgram.KeyBucketer extends Object implements Bucketer<Tuple4<Integer,Long,Integer,String>>
Constructor and Description |
---|
KeyBucketer() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.fs.Path |
getBucketPath(Clock clock,
org.apache.hadoop.fs.Path basePath,
Tuple4<Integer,Long,Integer,String> element)
Returns the
Path of a bucket file. |
public org.apache.hadoop.fs.Path getBucketPath(Clock clock, org.apache.hadoop.fs.Path basePath, Tuple4<Integer,Long,Integer,String> element)
Bucketer
Path
of a bucket file.getBucketPath
in interface Bucketer<Tuple4<Integer,Long,Integer,String>>
basePath
- The base path containing all the buckets.element
- The current element being processed.Path
of the bucket which the provided element should fall in. This
should include the basePath
and also the subtaskIndex
to avoid clashes with
parallel sinks.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.