org.deeplearning4j.spark.datavec

Class RecordReaderFunction

java.lang.Object

org.deeplearning4j.spark.datavec.RecordReaderFunction

All Implemented Interfaces:

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

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

Turn a string in to a dataset based on a record reader

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RecordReaderFunction(org.datavec.api.records.reader.RecordReader recordReader, int labelIndex, int numPossibleLabels)
RecordReaderFunction(org.datavec.api.records.reader.RecordReader recordReader, int labelIndex, int numPossibleLabels, org.datavec.api.io.WritableConverter converter)

Method Summary

Modifier and Type	Method and Description
org.nd4j.linalg.dataset.DataSet	call(java.lang.String v1)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordReaderFunction

public RecordReaderFunction(org.datavec.api.records.reader.RecordReader recordReader,
                            int labelIndex,
                            int numPossibleLabels,
                            org.datavec.api.io.WritableConverter converter)

RecordReaderFunction

public RecordReaderFunction(org.datavec.api.records.reader.RecordReader recordReader,
                            int labelIndex,
                            int numPossibleLabels)

Method Detail

call

public org.nd4j.linalg.dataset.DataSet call(java.lang.String v1)
                                     throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception