public class EntryValveProcessor extends Object implements Processor, Schedulable
Constructor and Description |
---|
EntryValveProcessor(SiddhiAppContext siddhiAppContext) |
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 |
setNextProcessor(Processor processor)
Set next processor element in processor chain
|
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
public EntryValveProcessor(SiddhiAppContext siddhiAppContext)
public void process(ComplexEventChunk complexEventChunk)
process
in interface Processor
process
in interface Schedulable
complexEventChunk
- event chunk to be processedpublic Processor getNextProcessor()
getNextProcessor
in interface Processor
public void setNextProcessor(Processor processor)
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainCopyright © 2019. All rights reserved.