- All Implemented Interfaces:
- java.io.Serializable, org.apache.spark.api.java.function.FlatMapFunction<java.util.Iterator<org.apache.spark.input.PortableDataStream>,R>
public class ExecuteWorkerPDSFlatMap<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 DataSet objects, that can be loaded using a PortableDataStream
Used in both SparkDl4jMultiLayer and SparkComputationGraph implementations
- See Also:
- Serialized Form