Modifier and Type | Class and Description |
---|---|
class |
IncrementalExecutor
Incremental executor class which is responsible for performing incremental aggregation.
|
Modifier and Type | Method and Description |
---|---|
Executor |
IncrementalExecutor.getNextExecutor() |
Executor |
Executor.getNextExecutor()
Get next executor element in the execution chain.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor>> |
AggregationRuntime.getAggregationDurationExecutorMap() |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalExecutor.setNextExecutor(Executor nextExecutor) |
void |
Executor.setNextExecutor(Executor executor)
Set next executor element in execution chain
|
Modifier and Type | Method and Description |
---|---|
ComplexEventChunk<StreamEvent> |
IncrementalDataAggregator.aggregateInMemoryData(Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor> incrementalExecutorMap) |
void |
AggregationRuntime.setAggregationDurationExecutorMap(Map<String,Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor>> aggregationDurationExecutorMap) |
Constructor and Description |
---|
IncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
boolean isRoot,
Table table,
Executor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent,
String timeZone,
boolean waitUntillprocessFinish) |
Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> aggregationDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
List<ExpressionExecutor> outputExpressionExecutors,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
boolean isOptimisedLookup,
List<io.siddhi.query.api.execution.query.selection.OutputAttribute> defaultSelectorList,
List<String> groupByVariablesList,
boolean isLatestEventColAdded,
int baseAggregatorBeginIndex,
List<io.siddhi.query.api.expression.Expression> finalBaseExpressionList,
IncrementalDataPurger incrementalDataPurger,
IncrementalExecutorsInitialiser incrementalExecutorInitialiser,
SingleStreamRuntime singleStreamRuntime,
MetaStreamEvent tableMetaStreamEvent,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind,
String timeZone) |
IncrementalExecutorsInitialiser(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor> incrementalExecutorMap,
boolean isDistributed,
String shardId,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
String timeZone) |
Modifier and Type | Class and Description |
---|---|
class |
PersistedIncrementalExecutor
Incremental Executor implementation class for Persisted Aggregation
|
Modifier and Type | Method and Description |
---|---|
Executor |
PersistedIncrementalExecutor.getNextExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
PersistedIncrementalExecutor.setNextExecutor(Executor executor) |
Constructor and Description |
---|
PersistedIncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
Executor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent,
String timeZone,
Processor cudStreamProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
EntryValveExecutor
Entry point to incremental executors.
|
Modifier and Type | Method and Description |
---|---|
Executor |
EntryValveExecutor.getNextExecutor()
Get next executor element in the executor chain.
|
Modifier and Type | Method and Description |
---|---|
void |
EntryValveExecutor.setNextExecutor(Executor executor)
Set next executor element in executor chain
|
Modifier and Type | Method and Description |
---|---|
StreamEvent |
IncrementalAggregateCompileCondition.find(StateEvent matchingEvent,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
ExpressionExecutor shouldUpdateTimestamp,
String timeZone) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor>> |
AggregationParser.getAggregationDurationExecutorMap() |
Copyright © 2021. All rights reserved.