public class IncrementalAggregateCompileCondition extends Object implements CompiledCondition
Constructor and Description |
---|
IncrementalAggregateCompileCondition(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
CompiledCondition onCompiledCondition,
MetaStreamEvent tableMetaStreamEvent,
MetaStreamEvent aggregateMetaSteamEvent,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
boolean isProcessingOnExternalTime) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
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) |
List<io.siddhi.query.api.definition.Attribute> |
getAdditionalAttributes() |
MatchingMetaInfoHolder |
getAlteredMatchingMetaInfoHolder() |
void |
setComplexEventPopulater(ComplexEventPopulater complexEventPopulater) |
public IncrementalAggregateCompileCondition(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions, CompiledCondition inMemoryStoreCompileCondition, CompiledCondition onCompiledCondition, MetaStreamEvent tableMetaStreamEvent, MetaStreamEvent aggregateMetaSteamEvent, List<io.siddhi.query.api.definition.Attribute> additionalAttributes, MatchingMetaInfoHolder alteredMatchingMetaInfoHolder, ExpressionExecutor perExpressionExecutor, ExpressionExecutor startTimeEndTimeExpressionExecutor, boolean isProcessingOnExternalTime)
public StreamEvent 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)
public void setComplexEventPopulater(ComplexEventPopulater complexEventPopulater)
public List<io.siddhi.query.api.definition.Attribute> getAdditionalAttributes()
public MatchingMetaInfoHolder getAlteredMatchingMetaInfoHolder()
Copyright © 2019. All rights reserved.