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,
IncrementalExecutor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent) |
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, IncrementalExecutor child, SiddhiQueryContext siddhiQueryContext, MetaStreamEvent metaStreamEvent)
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)
public void setProcessingExecutor(boolean processingExecutor)
Copyright © 2019. All rights reserved.