Package | Description |
---|---|
io.siddhi.core | |
io.siddhi.core.partition | |
io.siddhi.core.util | |
io.siddhi.core.util.parser |
Constructor and Description |
---|
SiddhiAppRuntime(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,
InputManager inputManager,
Map<String,QueryRuntime> queryProcessorMap,
Map<String,StreamJunction> streamJunctionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
ConcurrentMap<String,AggregationRuntime> aggregationMap,
Map<String,List<Source>> sourceMap,
Map<String,List<Sink>> sinkMap,
Map<String,PartitionRuntime> partitionMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionRuntime.addPartitionReceiver(QueryRuntime queryRuntime,
List<VariableExpressionExecutor> executors,
MetaStateEvent metaEvent) |
void |
PartitionRuntime.addQuery(QueryRuntime metaQueryRuntime) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionStreamReceiver.addStreamJunction(List<QueryRuntime> queryRuntimeList)
create local streamJunctions through which events received by partitionStreamReceiver, are sent to
queryStreamReceivers
|
Modifier and Type | Method and Description |
---|---|
String |
SiddhiAppRuntimeBuilder.addQuery(QueryRuntime queryRuntime) |
Modifier and Type | Method and Description |
---|---|
static QueryRuntime |
QueryParser.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.
|
Copyright © 2019. All rights reserved.