public class PortableDataStreamMultiDataSetIterator
extends java.lang.Object
implements org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
MultiDataSet.save(OutputStream)
) from
a PortableDataStream
, usually obtained from SparkContext.binaryFiles()Constructor and Description |
---|
PortableDataStreamMultiDataSetIterator(java.util.Collection<org.apache.spark.input.PortableDataStream> dataSetStreams) |
PortableDataStreamMultiDataSetIterator(java.util.Iterator<org.apache.spark.input.PortableDataStream> iter) |
Modifier and Type | Method and Description |
---|---|
boolean |
asyncSupported() |
boolean |
hasNext() |
org.nd4j.linalg.dataset.api.MultiDataSet |
next() |
org.nd4j.linalg.dataset.api.MultiDataSet |
next(int num) |
void |
remove() |
void |
reset() |
boolean |
resetSupported() |
void |
setPreProcessor(org.nd4j.linalg.dataset.api.MultiDataSetPreProcessor preProcessor) |
public PortableDataStreamMultiDataSetIterator(java.util.Iterator<org.apache.spark.input.PortableDataStream> iter)
public PortableDataStreamMultiDataSetIterator(java.util.Collection<org.apache.spark.input.PortableDataStream> dataSetStreams)
public org.nd4j.linalg.dataset.api.MultiDataSet next(int num)
next
in interface org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
public boolean resetSupported()
resetSupported
in interface org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
public boolean asyncSupported()
asyncSupported
in interface org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
public void reset()
reset
in interface org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
public void setPreProcessor(org.nd4j.linalg.dataset.api.MultiDataSetPreProcessor preProcessor)
setPreProcessor
in interface org.nd4j.linalg.dataset.api.iterator.MultiDataSetIterator
public boolean hasNext()
hasNext
in interface java.util.Iterator<org.nd4j.linalg.dataset.api.MultiDataSet>
public org.nd4j.linalg.dataset.api.MultiDataSet next()
next
in interface java.util.Iterator<org.nd4j.linalg.dataset.api.MultiDataSet>
public void remove()
remove
in interface java.util.Iterator<org.nd4j.linalg.dataset.api.MultiDataSet>