public interface Processor
ComplexEventChunk
which will be processed by the Processor and then handed over to the next Processor
in-line.Modifier and Type | Method and Description |
---|---|
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
void |
setNextProcessor(Processor processor)
Set next processor element in processor chain
|
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
void process(ComplexEventChunk complexEventChunk)
complexEventChunk
- event chunk to be processedvoid process(List<ComplexEventChunk> complexEventChunks)
complexEventChunks
- event chunks to be processedProcessor getNextProcessor()
void setNextProcessor(Processor processor)
processor
- Processor to be set as next element of processor chainvoid setToLast(Processor processor)
processor
- Last processor in the chainCopyright © 2019. All rights reserved.