Package | Description |
---|---|
io.siddhi.core.query.input.stream.state.receiver | |
io.siddhi.core.util.parser |
Constructor and Description |
---|
SequenceMultiProcessStreamReceiver(String streamId,
int processCount,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
SequenceSingleProcessStreamReceiver(String streamId,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static StateStreamRuntime |
StateInputStreamParser.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.