public class EntryValveExecutor extends Object implements Executor, Schedulable
Constructor and Description |
---|
EntryValveExecutor(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
execute(ComplexEventChunk complexEventChunk)
Execute the handed StreamEvent
|
Executor |
getNextExecutor()
Get next executor element in the executor chain.
|
void |
process(ComplexEventChunk complexEventChunk)
Implements process method in Schedulable interface.
|
void |
setNextExecutor(Executor executor)
Set next executor element in executor chain
|
public EntryValveExecutor(SiddhiAppContext siddhiAppContext)
public void execute(ComplexEventChunk complexEventChunk)
public Executor getNextExecutor()
getNextExecutor
in interface Executor
public void setNextExecutor(Executor executor)
setNextExecutor
in interface Executor
executor
- Executor to be set as next element of executor chainpublic void process(ComplexEventChunk complexEventChunk)
process
in interface Schedulable
complexEventChunk
- event chunk to be executedCopyright © 2019. All rights reserved.