org.canova.api.records.reader.impl

Class CSVRecordReader

java.lang.Object

org.canova.api.records.reader.impl.LineRecordReader

org.canova.api.records.reader.impl.CSVRecordReader

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Configurable, RecordReader

public class CSVRecordReader
extends LineRecordReader

Simple csv record reader.

Author:

Adam Gibson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELIMITER
static String	SKIP_NUM_LINES

Fields inherited from class org.canova.api.records.reader.impl.LineRecordReader

conf

Fields inherited from interface org.canova.api.records.reader.RecordReader

APPEND_LABEL, LABELS, NAME_SPACE

Constructor Summary

Constructors

Constructor and Description
CSVRecordReader()
CSVRecordReader(int skipNumLines) Skip first n lines
CSVRecordReader(int skipNumLines, String delimiter) Skip lines and use delimiter

Method Summary

Modifier and Type	Method and Description
void	initialize(Configuration conf, InputSplit split) Called once at initialization.
Collection<Writable>	next() Get the next record

Methods inherited from class org.canova.api.records.reader.impl.LineRecordReader

close, getConf, hasNext, initialize, setConf

Methods inherited from class java.lang.Object

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

Field Detail

SKIP_NUM_LINES

public static final String SKIP_NUM_LINES

DELIMITER

public static final String DELIMITER

Constructor Detail

CSVRecordReader

public CSVRecordReader(int skipNumLines)

Skip first n lines

Parameters:

skipNumLines - the number of lines to skip

CSVRecordReader

public CSVRecordReader(int skipNumLines,
                       String delimiter)

Skip lines and use delimiter

Parameters:

skipNumLines - the number of lines to skip

delimiter - the delimiter

CSVRecordReader

public CSVRecordReader()

Method Detail

initialize

public void initialize(Configuration conf,
                       InputSplit split)
                throws IOException,
                       InterruptedException

Description copied from interface: RecordReader

Called once at initialization.

Specified by:

initialize in interface RecordReader

Overrides:

initialize in class LineRecordReader

Parameters:

conf - a configuration for initialization

split - the split that defines the range of records to read

Throws:

IOException

InterruptedException

next

public Collection<Writable> next()

Description copied from interface: RecordReader

Get the next record

Specified by:

next in interface RecordReader

Overrides:

next in class LineRecordReader

Returns: