T- Type of object in the partition
public class FixedSizeBlockingChunkPartitioner<T> extends Object implements Partitioner<T>
FixedSizeBlockingChunkPartitionerdynamically partitions data into chunks of a fixed length. The partitioner does not need to know about the length of the data apriori. Beyond a
FixedSizeChunkPartitionerthis implementation doesn't use an underlying iterator. It can only be instantiated on queues and will always report to have more items available while it waits for the queue to be filled.
|Constructor and Description|
Construct with data in the form of a
Construct with data in the form of an
public FixedSizeBlockingChunkPartitioner(Queue<T> objects)
Queue. The number of items per chunk is set at the default value (20).
Queuerepresenting the data.