Constructor and Description |
---|
PersistedIncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
Executor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent,
String timeZone,
Processor cudStreamProcessor) |
Modifier and Type | Method and Description |
---|---|
void |
execute(ComplexEventChunk streamEventChunk)
Execute the handed StreamEvent
|
Executor |
getNextExecutor()
Get next executor element in the execution chain.
|
void |
setEmitTime(long emitTimeOfLatestEventInTable) |
void |
setNextExecutor(Executor executor)
Set next executor element in execution chain
|
void |
setProcessingExecutor(boolean processingExecutor) |
public PersistedIncrementalExecutor(String aggregatorName, io.siddhi.query.api.aggregation.TimePeriod.Duration duration, List<ExpressionExecutor> processExpressionExecutors, Executor child, SiddhiQueryContext siddhiQueryContext, MetaStreamEvent metaStreamEvent, String timeZone, Processor cudStreamProcessor)
public void execute(ComplexEventChunk streamEventChunk)
Executor
public void setEmitTime(long emitTimeOfLatestEventInTable)
setEmitTime
in interface Executor
public void setProcessingExecutor(boolean processingExecutor)
public Executor getNextExecutor()
Executor
getNextExecutor
in interface Executor
public void setNextExecutor(Executor executor)
Executor
setNextExecutor
in interface Executor
executor
- Event executor for incremental executionCopyright © 2021. All rights reserved.