Constructor and Description |
---|
AggregationRuntime(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,
SingleStreamRuntime singleStreamRuntime,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
MetaStreamEvent tableMetaStreamEvent,
List<ExpressionExecutor> outputExpressionExecutors,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind,
RecreateInMemoryData recreateInMemoryData,
boolean processingOnExternalTime,
List<GroupByKeyGenerator> groupByKeyGeneratorList,
IncrementalDataPurging incrementalDataPurging,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions,
ExpressionExecutor shouldUpdateTimestamp,
List<List<ExpressionExecutor>> aggregateProcessExpressionExecutorsListForFind) |
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
LatencyTracker |
SiddhiQueryContext.getLatencyTracker() |
Modifier and Type | Method and Description |
---|---|
void |
SiddhiQueryContext.setLatencyTracker(LatencyTracker latencyTracker) |
Modifier and Type | Field and Description |
---|---|
protected LatencyTracker |
OutputRateLimiter.latencyTracker |
Modifier and Type | Method and Description |
---|---|
void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder mapOptionHolder,
List<io.siddhi.query.api.annotation.Element> unmappedPayloadList,
Sink sink,
ConfigReader mapperConfigReader,
LatencyTracker mapperLatencyTracker,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
Scheduler.setLatencyTracker(LatencyTracker latencyTracker) |
Modifier and Type | Method and Description |
---|---|
static LatencyTracker |
QueryParserHelper.createLatencyTracker(SiddhiAppContext siddhiAppContext,
String name,
String type,
String function) |
Modifier and Type | Method and Description |
---|---|
LatencyTracker |
StatisticsTrackerFactory.createLatencyTracker(String name,
StatisticsManager statisticsManager) |
Modifier and Type | Class and Description |
---|---|
class |
SiddhiLatencyMetric
Class to calculate Siddhi latency.
|
Modifier and Type | Method and Description |
---|---|
LatencyTracker |
SiddhiMetricsFactory.createLatencyTracker(String name,
StatisticsManager statisticsManager) |
Copyright © 2019. All rights reserved.