public class AggregationRuntime extends Object implements MemoryCalculable
Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
SingleStreamRuntime singleStreamRuntime,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
MetaStreamEvent tableMetaStreamEvent,
List<ExpressionExecutor> outputExpressionExecutors,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind,
RecreateInMemoryData recreateInMemoryData,
boolean processingOnExternalTime,
List<GroupByKeyGenerator> groupByKeyGeneratorList,
IncrementalDataPurging incrementalDataPurging,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions,
ExpressionExecutor shouldUpdateTimestamp,
List<List<ExpressionExecutor>> aggregateProcessExpressionExecutorsListForFind) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
compileExpression(io.siddhi.query.api.expression.Expression expression,
io.siddhi.query.api.aggregation.Within within,
io.siddhi.query.api.expression.Expression per,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
StreamEvent |
find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
SiddhiQueryContext siddhiQueryContext) |
io.siddhi.query.api.definition.AggregationDefinition |
getAggregationDefinition() |
SingleStreamRuntime |
getSingleStreamRuntime() |
void |
processEvents(ComplexEventChunk<StreamEvent> streamEventComplexEventChunk) |
void |
recreateInMemoryData(boolean isEventArrived,
boolean refreshReadingExecutors) |
void |
startPurging() |
public AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables, SingleStreamRuntime singleStreamRuntime, List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations, MetaStreamEvent tableMetaStreamEvent, List<ExpressionExecutor> outputExpressionExecutors, LatencyTracker latencyTrackerFind, ThroughputTracker throughputTrackerFind, RecreateInMemoryData recreateInMemoryData, boolean processingOnExternalTime, List<GroupByKeyGenerator> groupByKeyGeneratorList, IncrementalDataPurging incrementalDataPurging, String shardId, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions, ExpressionExecutor shouldUpdateTimestamp, List<List<ExpressionExecutor>> aggregateProcessExpressionExecutorsListForFind)
public io.siddhi.query.api.definition.AggregationDefinition getAggregationDefinition()
public SingleStreamRuntime getSingleStreamRuntime()
public StreamEvent find(StateEvent matchingEvent, CompiledCondition compiledCondition, SiddhiQueryContext siddhiQueryContext)
public CompiledCondition compileExpression(io.siddhi.query.api.expression.Expression expression, io.siddhi.query.api.aggregation.Within within, io.siddhi.query.api.expression.Expression per, MatchingMetaInfoHolder matchingMetaInfoHolder, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, SiddhiQueryContext siddhiQueryContext)
public void startPurging()
public void recreateInMemoryData(boolean isEventArrived, boolean refreshReadingExecutors)
public void processEvents(ComplexEventChunk<StreamEvent> streamEventComplexEventChunk)
Copyright © 2019. All rights reserved.