roffild.spark

Class MLPDataFileRecordReaderVector

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<java.lang.String[],org.apache.spark.sql.Row>

roffild.spark.MLPDataFileRecordReader

roffild.spark.MLPDataFileRecordReaderVector

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class MLPDataFileRecordReaderVector
extends MLPDataFileRecordReader

Field Summary

Fields inherited from class roffild.spark.MLPDataFileRecordReader

data, header, mlpfile, nin, nout, size

Constructor Summary

Constructors

Constructor and Description
MLPDataFileRecordReaderVector()

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.Row	getCurrentValue()

Methods inherited from class roffild.spark.MLPDataFileRecordReader

close, getCurrentKey, getProgress, initialize, nextKeyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

MLPDataFileRecordReaderVector

public MLPDataFileRecordReaderVector()

Method Detail

getCurrentValue

public org.apache.spark.sql.Row getCurrentValue()
                                         throws java.io.IOException,
                                                java.lang.InterruptedException

Overrides:

getCurrentValue in class MLPDataFileRecordReader

Throws:

java.io.IOException

java.lang.InterruptedException