org.canova.api.records.reader.impl

Class FileRecordReader

java.lang.Object

org.canova.api.records.reader.impl.FileRecordReader

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Configurable, RecordReader

Direct Known Subclasses:

MatlabRecordReader

public class FileRecordReader
extends Object
implements RecordReader

File reader/writer

Author:

Adam Gibson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	appendLabel
protected Configuration	conf
protected File	currentFile
protected Iterator<File>	iter
protected List<String>	labels

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

APPEND_LABEL, LABELS, NAME_SPACE

Constructor Summary

Constructors

Constructor and Description
FileRecordReader()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	doInitialize(InputSplit split)
Configuration	getConf() Return the configuration used by this object.
protected int	getCurrentLabel() Return the current label.
List<String>	getLabels()
boolean	hasNext() Whether there are anymore records
void	initialize(Configuration conf, InputSplit split) Called once at initialization.
void	initialize(InputSplit split) Called once at initialization.
Collection<Writable>	next() Get the next record
void	setConf(Configuration conf) Set the configuration to be used by this object.
void	setLabels(List<String> labels)

Methods inherited from class java.lang.Object

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

Field Detail

iter

protected Iterator<File> iter

conf

protected Configuration conf

currentFile

protected File currentFile

labels

protected List<String> labels

appendLabel

protected boolean appendLabel

Constructor Detail

FileRecordReader

public FileRecordReader()

Method Detail

initialize

public void initialize(InputSplit split)
                throws IOException,
                       InterruptedException

Description copied from interface: RecordReader

Called once at initialization.

Specified by:

initialize in interface RecordReader

Parameters:

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

Throws:

IOException

InterruptedException

doInitialize

protected void doInitialize(InputSplit split)

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

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

Returns:

getCurrentLabel

protected int getCurrentLabel()

Return the current label. The index of the current file's parent directory in the label list

Returns:

The index of the current file's parent directory

getLabels

public List<String> getLabels()

setLabels

public void setLabels(List<String> labels)

hasNext

public boolean hasNext()

Description copied from interface: RecordReader

Whether there are anymore records

Specified by:

hasNext in interface RecordReader

Returns:

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

setConf

public void setConf(Configuration conf)

Description copied from interface: Configurable

Set the configuration to be used by this object.

Specified by:

setConf in interface Configurable

getConf

public Configuration getConf()

Description copied from interface: Configurable

Return the configuration used by this object.

Specified by:

getConf in interface Configurable