public interface Executor
IncrementalExecutor
) corresponds to a duration specified in
TimePeriod.Duration
.
Apart from that, EntryValveExecutor
which is a special implementation of this interface, marks the entry point to the rest of the
incremental executors. All of these executors are chained in such a way, that
EntryValveExecutor
links to the first
IncrementalExecutor
corresponding to the minimum duration, and the rest of the IncrementalExecutor
s
link in ascending order of durations. A ComplexEventChunk
received by a certain executor
would thus be handed over to next executor in-line.Modifier and Type | Method and Description |
---|---|
void |
execute(ComplexEventChunk complexEventChunk)
Execute the handed StreamEvent
|
Executor |
getNextExecutor()
Get next executor element in the execution chain.
|
void |
setNextExecutor(Executor executor)
Set next executor element in execution chain
|
void execute(ComplexEventChunk complexEventChunk)
complexEventChunk
- event chunk to be processedExecutor getNextExecutor()
void setNextExecutor(Executor executor)
executor
- Event executor for incremental executionCopyright © 2019. All rights reserved.