public class AggregationParser extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AggregationParser.Database |
Constructor and Description |
---|
AggregationParser() |
Modifier and Type | Method and Description |
---|---|
static StreamEvent |
createRestEvent(MetaStreamEvent metaStreamEvent,
StreamEvent streamEvent) |
static Map<String,Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Executor>> |
getAggregationDurationExecutorMap() |
static AggregationRuntime |
parse(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
SiddhiAppContext siddhiAppContext,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
SiddhiAppRuntimeBuilder siddhiAppRuntimeBuilder) |
public static AggregationRuntime parse(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition, SiddhiAppContext siddhiAppContext, Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap, Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap, Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap, Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap, Map<String,Table> tableMap, Map<String,Window> windowMap, Map<String,AggregationRuntime> aggregationMap, SiddhiAppRuntimeBuilder siddhiAppRuntimeBuilder)
public static StreamEvent createRestEvent(MetaStreamEvent metaStreamEvent, StreamEvent streamEvent)
Copyright © 2021. All rights reserved.