Package | Description |
---|---|
io.siddhi.core.aggregation | |
io.siddhi.core.query.selector | |
io.siddhi.core.util.collection.operator |
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) |
IncrementalExternalTimestampDataAggregator(List<ExpressionExecutor> baseExecutors,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext,
ExpressionExecutor shouldUpdateTimestamp) |
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 |
---|---|
void |
QuerySelector.setGroupByKeyGenerator(GroupByKeyGenerator groupByKeyGenerator) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
IncrementalAggregateCompileCondition.find(StateEvent matchingEvent,
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,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
List<ExpressionExecutor> baseExecutorsForFind,
List<ExpressionExecutor> outputExpressionExecutors,
SiddhiQueryContext siddhiQueryContext,
List<List<ExpressionExecutor>> aggregateProcessingExecutorsListForFind,
List<GroupByKeyGenerator> groupbyKeyGeneratorList,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions) |
Copyright © 2019. All rights reserved.