public class StreamPartitioner<ITEM extends IConverterInput> extends java.lang.Object implements INamespaceReader<IReader<MappedCdmBase<? extends CdmBase>>>
Constructor and Description |
---|
StreamPartitioner(INamespaceReader<ITEM> input,
IPartitionableConverter converter,
StreamImportStateBase<StreamImportConfiguratorBase,StreamImportBase> state,
java.lang.Integer size) |
Modifier and Type | Method and Description |
---|---|
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<? extends CdmBase>> |
read()
Returns the next Object of this reader.
|
public StreamPartitioner(INamespaceReader<ITEM> input, IPartitionableConverter converter, StreamImportStateBase<StreamImportConfiguratorBase,StreamImportBase> state, java.lang.Integer size)
public boolean hasNext()
IReader
hasNext
in interface IReader<IReader<MappedCdmBase<? extends CdmBase>>>
public IReader<MappedCdmBase<? extends CdmBase>> read()
IReader
null
if no object is left.read
in interface IReader<IReader<MappedCdmBase<? extends CdmBase>>>
public TermUri getTerm()
INamespace
getTerm
in interface INamespace
Copyright © 2007-2020 EDIT. All Rights Reserved.