Constructor and Description |
---|
IncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
boolean isRoot,
Table table,
Executor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent,
String timeZone,
boolean waitUntillprocessFinish) |
Modifier and Type | Method and Description |
---|---|
void |
execute(ComplexEventChunk streamEventChunk)
Execute the handed StreamEvent
|
long |
getAggregationStartTimestamp() |
Executor |
getNextExecutor()
Get next executor element in the execution chain.
|
void |
setEmitTime(long emitTimeOfLatestEventInTable) |
void |
setNextExecutor(Executor nextExecutor)
Set next executor element in execution chain
|
void |
setProcessingExecutor(boolean processingExecutor) |
void |
setScheduler(Scheduler scheduler) |
public IncrementalExecutor(String aggregatorName, io.siddhi.query.api.aggregation.TimePeriod.Duration duration, List<ExpressionExecutor> processExpressionExecutors, ExpressionExecutor shouldUpdateTimestamp, GroupByKeyGenerator groupByKeyGenerator, boolean isRoot, Table table, Executor child, SiddhiQueryContext siddhiQueryContext, MetaStreamEvent metaStreamEvent, String timeZone, boolean waitUntillprocessFinish)
public void setScheduler(Scheduler scheduler)
public void execute(ComplexEventChunk streamEventChunk)
Executor
public Executor getNextExecutor()
Executor
getNextExecutor
in interface Executor
public void setNextExecutor(Executor nextExecutor)
Executor
setNextExecutor
in interface Executor
nextExecutor
- Event executor for incremental executionpublic long getAggregationStartTimestamp()
public void setEmitTime(long emitTimeOfLatestEventInTable)
setEmitTime
in interface Executor
public void setProcessingExecutor(boolean processingExecutor)
Copyright © 2021. All rights reserved.