com.servingxml.components.recordio
Class RecordReaderPrefilter

java.lang.Object
  extended by com.servingxml.components.recordio.RecordReaderPrefilter
All Implemented Interfaces:
RecordReader

public class RecordReaderPrefilter
extends java.lang.Object
implements RecordReader


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
RecordReaderPrefilter(RecordReader recordReader, ParameterDescriptor[] parameterDescriptors)
           
 
Method Summary
 void discardRecord(ServiceContext context, Flow flow, ServingXmlException e)
           
 RecordWriter getDiscardWriter()
           
 Expirable getExpirable()
           
 Key getKey()
           
 RecordWriter getRecordWriter()
           
 void readRecords(ServiceContext context, Flow flow)
           
 void setDiscardWriter(RecordWriter discardWriter)
           
 void setRecordWriter(RecordWriter recordWriter)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RecordReaderPrefilter

public RecordReaderPrefilter(RecordReader recordReader,
                             ParameterDescriptor[] parameterDescriptors)
Method Detail

getRecordWriter

public RecordWriter getRecordWriter()
Specified by:
getRecordWriter in interface RecordReader

setRecordWriter

public void setRecordWriter(RecordWriter recordWriter)
Specified by:
setRecordWriter in interface RecordReader

getDiscardWriter

public RecordWriter getDiscardWriter()
Specified by:
getDiscardWriter in interface RecordReader

setDiscardWriter

public void setDiscardWriter(RecordWriter discardWriter)
Specified by:
setDiscardWriter in interface RecordReader

readRecords

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

getKey

public Key getKey()
Specified by:
getKey in interface RecordReader

getExpirable

public Expirable getExpirable()
Specified by:
getExpirable in interface RecordReader

discardRecord

public void discardRecord(ServiceContext context,
                          Flow flow,
                          ServingXmlException e)
Specified by:
discardRecord in interface RecordReader