org.openimaj.util.parallel.partition

Class FixedSizeChunkPartitioner<T>

java.lang.Object

org.openimaj.util.parallel.partition.FixedSizeChunkPartitioner<T>

Type Parameters:

T - Type of object in the partition

All Implemented Interfaces:

Partitioner<T>

public class FixedSizeChunkPartitioner<T>
extends Object
implements Partitioner<T>

A FixedSizeChunkPartitioner dynamically partitions data into chunks of a fixed length. The partitioner does not need to know about the length of the data apriori.

Author:

Jonathon Hare (jsh2@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
FixedSizeChunkPartitioner(Iterable<T> objects) Construct with data in the form of an Iterable.
FixedSizeChunkPartitioner(Iterable<T> objects, int chunkSize) Construct with data in the form of an Iterable and the given number of items per chunk.

Method Summary

Modifier and Type	Method and Description
Iterator<Iterator<T>>	getPartitions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedSizeChunkPartitioner

public FixedSizeChunkPartitioner(Iterable<T> objects)

Construct with data in the form of an Iterable. The number of items per chunk is set at the default value (20).

Parameters:

objects - the Iterable representing the data.

FixedSizeChunkPartitioner

public FixedSizeChunkPartitioner(Iterable<T> objects,
                                 int chunkSize)

Construct with data in the form of an Iterable and the given number of items per chunk.

Parameters:

objects - the Iterable representing the data.

chunkSize - number of items in each chunk.

Method Detail

getPartitions

public Iterator<Iterator<T>> getPartitions()

Specified by:

getPartitions in interface Partitioner<T>

Returns:

the partitioned data.