public class StateInputStreamParser extends Object
StateStreamRuntime
Constructor and Description |
---|
StateInputStreamParser() |
Modifier and Type | Method and Description |
---|---|
static StateStreamRuntime |
parseInputStream(io.siddhi.query.api.execution.query.input.stream.StateInputStream stateInputStream,
MetaStateEvent metaStateEvent,
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,
List<VariableExpressionExecutor> variableExpressionExecutors,
SiddhiQueryContext siddhiQueryContext) |
public static StateStreamRuntime parseInputStream(io.siddhi.query.api.execution.query.input.stream.StateInputStream stateInputStream, MetaStateEvent metaStateEvent, 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, List<VariableExpressionExecutor> variableExpressionExecutors, SiddhiQueryContext siddhiQueryContext)
Copyright © 2021. All rights reserved.