com.servingxml.components.recordio
Class RecordWriterFilterAdaptor
java.lang.Object
com.servingxml.components.recordio.AbstractRecordFilter
com.servingxml.components.recordio.RecordWriterFilterAdaptor
- All Implemented Interfaces:
- RecordFilter, RecordReader, RecordWriter
public final class RecordWriterFilterAdaptor
- extends AbstractRecordFilter
- implements RecordFilter
Fields inherited from interface com.servingxml.components.recordio.RecordFilter |
NULL |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RecordWriterFilterAdaptor
public RecordWriterFilterAdaptor(RecordWriter recordWriter)
readRecords
public final void readRecords(ServiceContext context,
Flow flow)
- Specified by:
readRecords
in interface RecordReader
- Overrides:
readRecords
in class AbstractRecordFilter
getKey
public final Key getKey()
- Specified by:
getKey
in interface RecordReader
- Overrides:
getKey
in class AbstractRecordFilter
getExpirable
public final Expirable getExpirable()
- Specified by:
getExpirable
in interface RecordReader
- Overrides:
getExpirable
in class AbstractRecordFilter
setRecordWriter
public final void setRecordWriter(RecordWriter recordWriter)
- Specified by:
setRecordWriter
in interface RecordReader
- Overrides:
setRecordWriter
in class AbstractRecordFilter
startRecordStream
public final void startRecordStream(ServiceContext context,
Flow flow)
- Specified by:
startRecordStream
in interface RecordWriter
- Overrides:
startRecordStream
in class AbstractRecordFilter
endRecordStream
public final void endRecordStream(ServiceContext context,
Flow flow)
- Specified by:
endRecordStream
in interface RecordWriter
- Overrides:
endRecordStream
in class AbstractRecordFilter
writeRecord
public final void writeRecord(ServiceContext context,
Flow flow)
- Specified by:
writeRecord
in interface RecordWriter
- Overrides:
writeRecord
in class AbstractRecordFilter
close
public final void close()
- Specified by:
close
in interface RecordWriter
- Overrides:
close
in class AbstractRecordFilter