com.servingxml.components.flatfile.layout
Class FlatFileReader

java.lang.Object
  extended by com.servingxml.components.recordio.AbstractRecordReader
      extended by com.servingxml.components.flatfile.layout.FlatFileReader
All Implemented Interfaces:
RecordReader

public class FlatFileReader
extends AbstractRecordReader
implements RecordReader

A DelimitedFlatFileReader implements a RecordReader interface.


Nested Class Summary
 
Nested classes/interfaces inherited from interface com.servingxml.components.recordio.RecordReader
RecordReader.NullRecordReader
 
Field Summary
 
Fields inherited from interface com.servingxml.components.recordio.RecordReader
NULL
 
Constructor Summary
FlatFileReader(FlatFileScanner flatFileScanner, FlatRecordReader[] headerReaders, FlatRecordReader[] trailerReaders, FlatRecordReader flatRecordReaderResolver, FlatFileSignature[] flatFileSignatures, StreamSource source, long fromRecord, long maxRecordCount, boolean lineDelimited)
           
 
Method Summary
 Expirable getExpirable()
           
 Key getKey()
           
 void readRecords(ServiceContext context, Flow flow)
           
 
Methods inherited from class com.servingxml.components.recordio.AbstractRecordReader
close, discardRecord, endRecordStream, getDiscardWriter, getRecordWriter, setDiscardWriter, setRecordWriter, startRecordStream, writeRecord
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface com.servingxml.components.recordio.RecordReader
discardRecord, getDiscardWriter, getRecordWriter, setDiscardWriter, setRecordWriter
 

Constructor Detail

FlatFileReader

public FlatFileReader(FlatFileScanner flatFileScanner,
                      FlatRecordReader[] headerReaders,
                      FlatRecordReader[] trailerReaders,
                      FlatRecordReader flatRecordReaderResolver,
                      FlatFileSignature[] flatFileSignatures,
                      StreamSource source,
                      long fromRecord,
                      long maxRecordCount,
                      boolean lineDelimited)
Method Detail

readRecords

public void readRecords(ServiceContext context,
                        Flow flow)
Specified by:
readRecords in interface RecordReader

getKey

public Key getKey()
Specified by:
getKey in interface RecordReader
Overrides:
getKey in class AbstractRecordReader

getExpirable

public Expirable getExpirable()
Specified by:
getExpirable in interface RecordReader
Overrides:
getExpirable in class AbstractRecordReader