Package | Description |
---|---|
io.siddhi.core.aggregation | |
io.siddhi.core.util.parser.helper | |
io.siddhi.core.util.statistics | |
io.siddhi.core.util.statistics.metrics |
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) |
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
static ThroughputTracker |
QueryParserHelper.createThroughputTracker(SiddhiAppContext siddhiAppContext,
String name,
String type,
String function) |
Modifier and Type | Method and Description |
---|---|
ThroughputTracker |
StatisticsTrackerFactory.createThroughputTracker(String name,
StatisticsManager statisticsManager) |
Modifier and Type | Class and Description |
---|---|
class |
SiddhiThroughputMetric
Class to calculate Siddhi throughput.
|
Modifier and Type | Method and Description |
---|---|
ThroughputTracker |
SiddhiMetricsFactory.createThroughputTracker(String name,
StatisticsManager statisticsManager) |
Copyright © 2021. All rights reserved.