eu.etaxonomy.cdm.io.dwca.in
Class StreamPartitioner<ITEM extends IConverterInput>

java.lang.Object
  eu.etaxonomy.cdm.io.dwca.in.StreamPartitioner<ITEM>

All Implemented Interfaces:

IConverterOutput<IReader<IReader<MappedCdmBase>>>, INamespace, INamespaceReader<IReader<MappedCdmBase>>, IReader<IReader<MappedCdmBase>>

public class StreamPartitioner<ITEM extends IConverterInput>
extends Object
implements INamespaceReader<IReader<MappedCdmBase>>

Author:

a.mueller

Constructor Summary

StreamPartitioner(INamespaceReader<ITEM> input, IPartitionableConverter converter, DwcaImportState state, Integer size)

Method Summary

TermUri	getTerm() Returns the namespace of the items included in the stream
boolean	hasNext() Checks the availablity of a next object in the stream.
IReader<MappedCdmBase>	read() Returns the next Object of this reader.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamPartitioner

public StreamPartitioner(INamespaceReader<ITEM> input,
                         IPartitionableConverter converter,
                         DwcaImportState state,
                         Integer size)

Method Detail

hasNext

public boolean hasNext()

Description copied from interface: IReader

Checks the availablity of a next object in the stream.

Specified by:

hasNext in interface IReader<IReader<MappedCdmBase>>

Returns:

True if there is a next object, false otherwise.

read

public IReader<MappedCdmBase> read()

Description copied from interface: IReader

Returns the next Object of this reader. Returns null if no object is left.

Specified by:

read in interface IReader<IReader<MappedCdmBase>>

Returns:

getTerm

public TermUri getTerm()

Description copied from interface: INamespace

Returns the namespace of the items included in the stream

Specified by:

getTerm in interface INamespace

Returns:

the term