public class SplitDataSetsFunction
extends org.datavec.spark.transform.BaseFlatMapFunctionAdaptee<java.util.Iterator<org.nd4j.linalg.dataset.DataSet>,org.nd4j.linalg.dataset.DataSet>
RDD<DataSet> myBatchedExampleDataSets = ...;
RDD<DataSet> singleExamlpeDataSets = myBatchedExampleDataSets.mapPartitions(new SplitDataSets(batchSize));
Constructor and Description |
---|
SplitDataSetsFunction() |