public class IncrementalExecutorsInitialiser extends Object
Constructor and Description |
---|
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 | Method and Description |
---|---|
void |
initialiseExecutors() |
public 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)
Copyright © 2021. All rights reserved.