public class JoinInputStreamParser extends Object
Constructor and Description |
---|
JoinInputStreamParser() |
Modifier and Type | Method and Description |
---|---|
static StreamRuntime |
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) |
public static StreamRuntime 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)
Copyright © 2019. All rights reserved.