org.easybatch.flatfile

Class FlatFileRecordReader

java.lang.Object

org.easybatch.flatfile.FlatFileRecordReader

All Implemented Interfaces:

RecordReader

public class FlatFileRecordReader
extends Object
implements RecordReader

A RecordReader implementation that read data from a flat file.

Author:

Mahmoud Ben Hassine (mahmoud@benhassine.fr)

Constructor Summary

Constructors

Constructor and Description
FlatFileRecordReader(File input) Constructs a flat file record reader.
FlatFileRecordReader(File input, String charsetName) Constructs a flat file record reader.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	getDataSourceName()
Long	getTotalRecords()
boolean	hasNextRecord()
void	open()
StringRecord	readNextRecord()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlatFileRecordReader

public FlatFileRecordReader(File input)
                     throws FileNotFoundException

Constructs a flat file record reader.

Parameters:

input - the input file

Throws:

FileNotFoundException - thrown if the file does not exist

FlatFileRecordReader

public FlatFileRecordReader(File input,
                    String charsetName)
                     throws FileNotFoundException

Constructs a flat file record reader.

Parameters:

input - the input file

charsetName - the encoding to use to read the file

Throws:

FileNotFoundException - thrown if the file does not exist

Method Detail

readNextRecord

public StringRecord readNextRecord()

Specified by:

readNextRecord in interface RecordReader

getTotalRecords

public Long getTotalRecords()

Specified by:

getTotalRecords in interface RecordReader

getDataSourceName

public String getDataSourceName()

Specified by:

getDataSourceName in interface RecordReader

open

public void open()
          throws Exception

Specified by:

open in interface RecordReader

Throws:

Exception

hasNextRecord

public boolean hasNextRecord()

Specified by:

hasNextRecord in interface RecordReader

close

public void close()

Specified by:

close in interface RecordReader