com.servingxml.components.recordio
Class AbstractRecordReaderFactory

java.lang.Object
  extended by com.servingxml.components.recordio.AbstractRecordReaderFactory
All Implemented Interfaces:
RecordFilterAppender, RecordPipelineAppender, RecordReaderFactory
Direct Known Subclasses:
CurrentRecordReaderFactory, DefaultFlatFileReaderFactory, DirectoryReaderFactory, FlatFileReaderFactory, ParameterReaderFactory, SqlGrepFactory, SqlReaderFactory, SubtreeRecordReaderFactory

public abstract class AbstractRecordReaderFactory
extends java.lang.Object
implements RecordReaderFactory, RecordFilterAppender

A FlatFileReaderFactory instance may be used to obtain objects that implement the RecordReader interface.


Field Summary
 
Fields inherited from interface com.servingxml.components.recordio.RecordPipelineAppender
EMPTY_ARRAY
 
Fields inherited from interface com.servingxml.components.recordio.RecordPipelineAppender
EMPTY_ARRAY
 
Constructor Summary
AbstractRecordReaderFactory()
           
 
Method Summary
 void appendToRecordPipeline(ServiceContext context, Flow flow, RecordFilterChain pipeline)
           
 RecordPipeline createRecordPipeline(ServiceContext context, Flow flow)
           
protected abstract  RecordReader createRecordReader(ServiceContext context, Flow flow)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractRecordReaderFactory

public AbstractRecordReaderFactory()
Method Detail

createRecordReader

protected abstract RecordReader createRecordReader(ServiceContext context,
                                                   Flow flow)

createRecordPipeline

public RecordPipeline createRecordPipeline(ServiceContext context,
                                           Flow flow)
Specified by:
createRecordPipeline in interface RecordPipelineAppender

appendToRecordPipeline

public void appendToRecordPipeline(ServiceContext context,
                                   Flow flow,
                                   RecordFilterChain pipeline)
Specified by:
appendToRecordPipeline in interface RecordPipelineAppender