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