org.datavec.spark.functions

Class LineRecordReaderFunction

java.lang.Object

org.datavec.spark.functions.LineRecordReaderFunction

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.Function<java.lang.String,java.util.List<Writable>>

public class LineRecordReaderFunction
extends java.lang.Object
implements org.apache.spark.api.java.function.Function<java.lang.String,java.util.List<Writable>>

LineRecordReaderFunction: Used to map a JavaRDD<String> to a JavaRDD<Collection<Writable>> Note that this is most useful with LineRecordReader instances (CSVRecordReader, SVMLightRecordReader, etc)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LineRecordReaderFunction(RecordReader recordReader)

Method Summary

Modifier and Type	Method and Description
java.util.List<Writable>	call(java.lang.String s)

Methods inherited from class java.lang.Object

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

Constructor Detail

LineRecordReaderFunction

public LineRecordReaderFunction(RecordReader recordReader)

Method Detail

call

public java.util.List<Writable> call(java.lang.String s)
                              throws java.lang.Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<java.lang.String,java.util.List<Writable>>

Throws:

java.lang.Exception