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>