public class RecreateInMemoryData extends Object
Constructor and Description |
---|
RecreateInMemoryData(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,IncrementalExecutor> incrementalExecutorMap,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions) |
Modifier and Type | Method and Description |
---|---|
void |
recreateInMemoryData(boolean refreshReadingExecutors) |
public RecreateInMemoryData(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,IncrementalExecutor> incrementalExecutorMap, SiddhiAppContext siddhiAppContext, MetaStreamEvent metaStreamEvent, Map<String,Table> tableMap, Map<String,Window> windowMap, Map<String,AggregationRuntime> aggregationMap, String shardId, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions)
Copyright © 2019. All rights reserved.