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 |
setEmitTime(long emitTimeOfLatestEventInTable) |
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 executedpublic void setEmitTime(long emitTimeOfLatestEventInTable)
setEmitTime
in interface Executor
Copyright © 2021. All rights reserved.