Class RecordFilterChainImpl
java.lang.Object
org.nuxeo.lib.stream.computation.internals.RecordFilterChainImpl
- All Implemented Interfaces:
RecordFilter
,RecordFilterChain
Chains multiple record filters.
- Since:
- 11.1
-
Field Summary
Modifier and TypeFieldDescriptionprotected final Deque<RecordFilter>
static final RecordFilterChain
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaddFilter
(RecordFilter filter) void
afterAppend
(Record record, LogOffset offset) Called after a record is appended to a stream.Called after reading a record.beforeAppend
(Record record) Called before appending a record to a stream.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.nuxeo.lib.stream.computation.RecordFilter
init
-
Field Details
-
NONE
-
filters
-
-
Constructor Details
-
RecordFilterChainImpl
public RecordFilterChainImpl()
-
-
Method Details
-
addFilter
- Specified by:
addFilter
in interfaceRecordFilterChain
-
beforeAppend
Description copied from interface:RecordFilter
Called before appending a record to a stream. This hook enables to change the record or to skip it when returning null.- Specified by:
beforeAppend
in interfaceRecordFilter
- Parameters:
record
- the record that will be appended to a stream
-
afterAppend
Description copied from interface:RecordFilter
Called after a record is appended to a stream.- Specified by:
afterAppend
in interfaceRecordFilter
- Parameters:
record
- the written recordoffset
- the record's offset
-
afterRead
Description copied from interface:RecordFilter
Called after reading a record. This hook enables to change the record or to skip it when returning null.- Specified by:
afterRead
in interfaceRecordFilter
- Parameters:
record
- the recordoffset
- the offset of the record
-