Constructor and Description |
---|
IncrementalDataPurger() |
Modifier and Type | Method and Description |
---|---|
void |
executeIncrementalDataPurging()
Data purging task scheduler method
|
void |
init(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
StreamEventFactory streamEventFactory,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Boolean isProcessingOnExternalTime,
SiddhiQueryContext siddhiQueryContext,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> activeIncrementalDurations,
String timeZone,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
boolean |
isPurgingEnabled() |
void |
run() |
void |
setPurgingEnabled(boolean purgingEnabled) |
public void init(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition, StreamEventFactory streamEventFactory, Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables, Boolean isProcessingOnExternalTime, SiddhiQueryContext siddhiQueryContext, List<io.siddhi.query.api.aggregation.TimePeriod.Duration> activeIncrementalDurations, String timeZone, Map<String,Window> windowMap, Map<String,AggregationRuntime> aggregationMap)
public boolean isPurgingEnabled()
public void setPurgingEnabled(boolean purgingEnabled)
public void executeIncrementalDataPurging()
Copyright © 2021. All rights reserved.