Package | Description |
---|---|
io.siddhi.core | |
io.siddhi.core.util |
Modifier and Type | Class and Description |
---|---|
class |
SiddhiAppRuntimeImpl
Keep streamDefinitions, partitionRuntimes, queryRuntimes of an SiddhiApp and streamJunctions and inputHandlers used.
|
Modifier and Type | Method and Description |
---|---|
SiddhiAppRuntime |
SiddhiManager.createSandboxSiddhiAppRuntime(io.siddhi.query.api.SiddhiApp siddhiApp)
Create a SiddhiApp Sandbox Runtime that runs without their Sources Sinks and Stores.
|
SiddhiAppRuntime |
SiddhiManager.createSandboxSiddhiAppRuntime(String siddhiApp)
Create a SiddhiApp Sandbox Runtime that runs without their Sources Sinks and Stores.
|
SiddhiAppRuntime |
SiddhiManager.createSiddhiAppRuntime(io.siddhi.query.api.SiddhiApp siddhiApp) |
SiddhiAppRuntime |
SiddhiManager.createSiddhiAppRuntime(String siddhiApp) |
SiddhiAppRuntime |
SiddhiManager.getSiddhiAppRuntime(String siddhiAppName)
Method to retrieve already submitted siddhi app by providing the name.
|
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,SiddhiAppRuntime> |
SiddhiManager.getSiddhiAppRuntimeMap()
Method used to get all SiddhiAppRuntimes
|
Constructor and Description |
---|
SiddhiAppRuntimeImpl(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,
ConcurrentMap<String,Trigger> triggerMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Modifier and Type | Method and Description |
---|---|
SiddhiAppRuntime |
SiddhiAppRuntimeBuilder.build() |
Modifier and Type | Method and Description |
---|---|
void |
SiddhiAppRuntimeBuilder.setSiddhiAppRuntimeMap(ConcurrentMap<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Copyright © 2019. All rights reserved.