static StreamRuntime |
InputStreamParser.parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
io.siddhi.query.api.execution.query.Query query,
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
|
static StreamRuntime |
JoinInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.JoinInputStream joinInputStream,
io.siddhi.query.api.execution.query.Query query,
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) |