public class SingleInputStreamParser extends Object
Constructor and Description |
---|
SingleInputStreamParser() |
Modifier and Type | Method and Description |
---|---|
static Processor |
generateProcessor(io.siddhi.query.api.execution.query.input.handler.StreamHandler streamHandler,
MetaComplexEvent metaEvent,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
static SingleStreamRuntime |
parseInputStream(io.siddhi.query.api.execution.query.input.stream.SingleInputStream inputStream,
List<VariableExpressionExecutor> variableExpressionExecutors,
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,
MetaComplexEvent metaComplexEvent,
ProcessStreamReceiver processStreamReceiver,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
boolean multiValue,
SiddhiQueryContext siddhiQueryContext)
Parse single InputStream and return SingleStreamRuntime
|
public static SingleStreamRuntime parseInputStream(io.siddhi.query.api.execution.query.input.stream.SingleInputStream inputStream, List<VariableExpressionExecutor> variableExpressionExecutors, 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, MetaComplexEvent metaComplexEvent, ProcessStreamReceiver processStreamReceiver, boolean supportsBatchProcessing, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, boolean multiValue, SiddhiQueryContext siddhiQueryContext)
inputStream
- single input stream to be parsedvariableExpressionExecutors
- List to hold VariableExpressionExecutors to update after query parsingstreamDefinitionMap
- Stream Definition MaptableDefinitionMap
- Table Definition MapwindowDefinitionMap
- window definition mapaggregationDefinitionMap
- aggregation definition maptableMap
- Table MapmetaComplexEvent
- MetaComplexEventprocessStreamReceiver
- ProcessStreamReceiversupportsBatchProcessing
- supports batch processingoutputExpectsExpiredEvents
- is expired events sent as outputfindToBeExecuted
- find will be executed in the steam storesmultiValue
- event has the possibility to produce multiple valuessiddhiQueryContext
- @return SingleStreamRuntimepublic static Processor generateProcessor(io.siddhi.query.api.execution.query.input.handler.StreamHandler streamHandler, MetaComplexEvent metaEvent, List<VariableExpressionExecutor> variableExpressionExecutors, Map<String,Table> tableMap, boolean supportsBatchProcessing, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, SiddhiQueryContext siddhiQueryContext)
Copyright © 2021. All rights reserved.