public class IncrementalDataAggregator extends Object
In-memory data is required to be aggregated when retrieving values from an aggregate. Table data (tables used to persist incremental aggregates) needs to be aggregated when querying aggregate data from a different server (apart from the server, which was used to define the aggregation).
Constructor and Description |
---|
IncrementalDataAggregator(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
io.siddhi.query.api.aggregation.TimePeriod.Duration durationToAggregate,
long oldestEventTimestamp,
List<ExpressionExecutor> baseExecutorsForFind,
ExpressionExecutor shouldUpdateTimestamp,
boolean groupBy,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Method and Description |
---|---|
ComplexEventChunk<StreamEvent> |
aggregateInMemoryData(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap) |
public IncrementalDataAggregator(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations, io.siddhi.query.api.aggregation.TimePeriod.Duration durationToAggregate, long oldestEventTimestamp, List<ExpressionExecutor> baseExecutorsForFind, ExpressionExecutor shouldUpdateTimestamp, boolean groupBy, MetaStreamEvent metaStreamEvent)
public ComplexEventChunk<StreamEvent> aggregateInMemoryData(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap)
Copyright © 2019. All rights reserved.