org.deeplearning4j.spark.impl.common

Class LoadSerializedDataSetFunction

java.lang.Object

org.deeplearning4j.spark.impl.common.LoadSerializedDataSetFunction

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.Function<org.apache.spark.input.PortableDataStream,org.nd4j.linalg.dataset.DataSet>

public class LoadSerializedDataSetFunction
extends java.lang.Object
implements org.apache.spark.api.java.function.Function<org.apache.spark.input.PortableDataStream,org.nd4j.linalg.dataset.DataSet>

This is a function that is used to load a DataSet object using DataSet.load(InputStream).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LoadSerializedDataSetFunction()

Method Summary

Modifier and Type	Method and Description
org.nd4j.linalg.dataset.DataSet	call(org.apache.spark.input.PortableDataStream pds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LoadSerializedDataSetFunction

public LoadSerializedDataSetFunction()

Method Detail

call

public org.nd4j.linalg.dataset.DataSet call(org.apache.spark.input.PortableDataStream pds)
                                     throws java.lang.Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<org.apache.spark.input.PortableDataStream,org.nd4j.linalg.dataset.DataSet>

Throws:

java.lang.Exception