IN
- The type of input elements.BucketID
- The type of ids for the buckets, as returned by the BucketAssigner
.@Internal public class Buckets<IN,BucketID> extends Object
StreamingFileSink
.
This class is responsible for all bucket-related operations and the actual
StreamingFileSink
is just plugging in the functionality offered by
this class to the lifecycle of the operator.
Modifier and Type | Method and Description |
---|---|
long |
getMaxPartCounter() |
@VisibleForTesting public long getMaxPartCounter()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.