T - Type of object in the partitionpublic class GrowingChunkPartitioner<T> extends Object implements Partitioner<T>
GrowingChunkPartitioner dynamically partitions data into chunks.
The partitioner does not need to know about the length of the data apriori.
The size of the chunks grows over time exponentially.| Constructor and Description |
|---|
GrowingChunkPartitioner(Iterable<T> objects)
Construct with data in the form of an
Iterable. |
public GrowingChunkPartitioner(Iterable<T> objects)
Iterable.objects - the Iterable representing the data.public Iterator<Iterator<T>> getPartitions()
getPartitions in interface Partitioner<T>