- All Implemented Interfaces:
- java.io.Serializable, org.apache.spark.api.java.function.FlatMapFunction<java.util.Iterator<org.apache.spark.input.PortableDataStream>,R>
public class ExecuteWorkerPDSMDSFlatMap<R extends TrainingResult>
extends org.datavec.spark.transform.BaseFlatMapFunctionAdaptee<java.util.Iterator<org.apache.spark.input.PortableDataStream>,R>
A FlatMapFunction for executing training on serialized MultiDataSet objects, that can be loaded using a PortableDataStream
Used for SparkComputationGraph implementations only
- See Also:
- Serialized Form