public class QueryParser extends Object
QueryRuntime
.Constructor and Description |
---|
QueryParser() |
Modifier and Type | Method and Description |
---|---|
static QueryRuntimeImpl |
parse(io.siddhi.query.api.execution.query.Query query,
SiddhiAppContext siddhiAppContext,
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,AggregationRuntime> aggregationMap,
Map<String,Window> windowMap,
LockSynchronizer lockSynchronizer,
String queryIndex,
boolean partitioned,
String partitionId)
Parse a query and return corresponding QueryRuntime.
|
public static QueryRuntimeImpl parse(io.siddhi.query.api.execution.query.Query query, SiddhiAppContext siddhiAppContext, 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,AggregationRuntime> aggregationMap, Map<String,Window> windowMap, LockSynchronizer lockSynchronizer, String queryIndex, boolean partitioned, String partitionId)
query
- query to be parsed.siddhiAppContext
- associated Siddhi app context.streamDefinitionMap
- keyvalue containing user given stream definitions.tableDefinitionMap
- keyvalue containing table definitions.windowDefinitionMap
- keyvalue containing window definition map.aggregationDefinitionMap
- keyvalue containing aggregation definition map.tableMap
- keyvalue containing event tables.aggregationMap
- keyvalue containing aggrigation runtimes.windowMap
- keyvalue containing event window map.lockSynchronizer
- Lock synchronizer for sync the lock across queries.queryIndex
- query index to identify unknown query by numberpartitioned
- is the query partitionedpartitionId
- The ID of the partitionCopyright © 2021. All rights reserved.