public class IncrementalAggregateCompileCondition extends Object implements CompiledCondition
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isStoreQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap,
List<ExpressionExecutor> outputExpressionExecutors,
boolean isOptimisedLookup,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition,
CompiledCondition onCompiledCondition,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
List<ExpressionExecutor> timestampFilterExecutors,
MetaStreamEvent aggregateMetaSteamEvent,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
MatchingMetaInfoHolder matchingHolderInfoForTableLookups,
List<VariableExpressionExecutor> variableExpExecutorsForTableLookups) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
find(StateEvent matchingEvent,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
ExpressionExecutor shouldUpdateTimestamp) |
List<io.siddhi.query.api.definition.Attribute> |
getAdditionalAttributes() |
MatchingMetaInfoHolder |
getAlteredMatchingMetaInfoHolder() |
void |
init() |
void |
setComplexEventPopulater(ComplexEventPopulater complexEventPopulater) |
public IncrementalAggregateCompileCondition(boolean isStoreQuery, String aggregationName, boolean isProcessingOnExternalTime, boolean isDistributed, List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap, List<ExpressionExecutor> outputExpressionExecutors, boolean isOptimisedLookup, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions, CompiledCondition inMemoryStoreCompileCondition, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition, CompiledCondition onCompiledCondition, List<io.siddhi.query.api.definition.Attribute> additionalAttributes, ExpressionExecutor perExpressionExecutor, ExpressionExecutor startTimeEndTimeExpressionExecutor, List<ExpressionExecutor> timestampFilterExecutors, MetaStreamEvent aggregateMetaSteamEvent, MatchingMetaInfoHolder alteredMatchingMetaInfoHolder, MatchingMetaInfoHolder matchingHolderInfoForTableLookups, List<VariableExpressionExecutor> variableExpExecutorsForTableLookups)
public void init()
public StreamEvent find(StateEvent matchingEvent, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap, ExpressionExecutor shouldUpdateTimestamp)
public void setComplexEventPopulater(ComplexEventPopulater complexEventPopulater)
public List<io.siddhi.query.api.definition.Attribute> getAdditionalAttributes()
public MatchingMetaInfoHolder getAlteredMatchingMetaInfoHolder()
Copyright © 2019. All rights reserved.