public class InputStreamParser extends Object
InputStream
Constructor and Description |
---|
InputStreamParser() |
Modifier and Type | Method and Description |
---|---|
static StreamRuntime |
parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
List<io.siddhi.query.api.expression.Variable> queryGroupByList,
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,
List<VariableExpressionExecutor> executors,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse an InputStream returning corresponding StreamRuntime
|
public static StreamRuntime parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream, List<io.siddhi.query.api.expression.Variable> queryGroupByList, 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, List<VariableExpressionExecutor> executors, boolean outputExpectsExpiredEvents, SiddhiQueryContext siddhiQueryContext)
inputStream
- input stream to be parsedstreamDefinitionMap
- map containing user given stream definitionstableDefinitionMap
- table definition mapwindowDefinitionMap
- window definition mapaggregationDefinitionMap
- aggregation definition maptableMap
- Table MapwindowMap
- event window mapaggregationMap
- aggregator mapexecutors
- List to hold VariableExpressionExecutors to update after query parsingoutputExpectsExpiredEvents
- is expired events sent as outputsiddhiQueryContext
- Siddhi query context.Copyright © 2019. All rights reserved.