public class SelectorParser extends Object
QuerySelector
.Constructor and Description |
---|
SelectorParser() |
Modifier and Type | Method and Description |
---|---|
static ThreadLocal<String> |
getContainsAggregatorThreadLocal() |
static QuerySelector |
parse(io.siddhi.query.api.execution.query.selection.Selector selector,
io.siddhi.query.api.execution.query.output.stream.OutputStream outputStream,
MetaComplexEvent metaComplexEvent,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> variableExpressionExecutors,
int metaPosition,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse Selector portion of a query and return corresponding QuerySelector.
|
public static QuerySelector parse(io.siddhi.query.api.execution.query.selection.Selector selector, io.siddhi.query.api.execution.query.output.stream.OutputStream outputStream, MetaComplexEvent metaComplexEvent, Map<String,Table> tableMap, List<VariableExpressionExecutor> variableExpressionExecutors, int metaPosition, ProcessingMode processingMode, boolean outputExpectsExpiredEvents, SiddhiQueryContext siddhiQueryContext)
selector
- selector to be parsedoutputStream
- output streammetaComplexEvent
- Meta event used to collect execution info of stream associated with querytableMap
- Table MapvariableExpressionExecutors
- variable expression executorsmetaPosition
- helps to identify the meta position of aggregatesprocessingMode
- processing mode of the queryoutputExpectsExpiredEvents
- is expired events sent as outputsiddhiQueryContext
- current siddhi query contextpublic static ThreadLocal<String> getContainsAggregatorThreadLocal()
Copyright © 2021. All rights reserved.