com.servingxml.components.recordio
Class RecordPipeline

java.lang.Object
  extended by com.servingxml.components.recordio.RecordPipeline
All Implemented Interfaces:
RecordFilterChain

public class RecordPipeline
extends java.lang.Object
implements RecordFilterChain


Constructor Summary
RecordPipeline(Flow flow, RecordReader recordReader)
           
 
Method Summary
 void addExpirable(Expirable expirable)
           
 void addRecordFilter(RecordFilter recordFilter)
           
 void execute(ServiceContext context)
           
 Expirable getExpirable()
           
 Key getKey()
           
 RecordReader getRecordReader()
           
 void setDiscardWriter(RecordWriter discardWriter)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RecordPipeline

public RecordPipeline(Flow flow,
                      RecordReader recordReader)
Method Detail

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