com.servingxml.components.recordio
Class RecordPipeline
java.lang.Object
com.servingxml.components.recordio.RecordPipeline
- All Implemented Interfaces:
- RecordFilterChain
public class RecordPipeline
- extends java.lang.Object
- implements RecordFilterChain
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RecordPipeline
public RecordPipeline(Flow flow,
RecordReader recordReader)
getRecordReader
public RecordReader getRecordReader()
addRecordFilter
public void addRecordFilter(RecordFilter recordFilter)
- Specified by:
addRecordFilter
in interface RecordFilterChain
getExpirable
public Expirable getExpirable()
getKey
public Key getKey()
addExpirable
public void addExpirable(Expirable expirable)
- Specified by:
addExpirable
in interface RecordFilterChain
execute
public void execute(ServiceContext context)
setDiscardWriter
public void setDiscardWriter(RecordWriter discardWriter)
- Specified by:
setDiscardWriter
in interface RecordFilterChain