public class SiddhiAppRuntimeBuilder extends Object
Constructor and Description |
---|
SiddhiAppRuntimeBuilder(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
addPartition(PartitionRuntime partitionRuntime) |
String |
addQuery(QueryRuntime queryRuntime) |
SiddhiAppRuntime |
build() |
void |
defineAggregation(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition) |
void |
defineFunction(io.siddhi.query.api.definition.FunctionDefinition functionDefinition) |
void |
defineStream(io.siddhi.query.api.definition.StreamDefinition streamDefinition) |
void |
defineTable(io.siddhi.query.api.definition.TableDefinition tableDefinition) |
void |
defineTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition) |
void |
defineWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition) |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getAggregationDefinitionMap() |
ConcurrentMap<String,AggregationRuntime> |
getAggregationMap() |
LockSynchronizer |
getLockSynchronizer() |
ConcurrentMap<String,List<Sink>> |
getSinkMap() |
ConcurrentMap<String,List<Source>> |
getSourceMap() |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getStreamDefinitionMap() |
ConcurrentMap<String,StreamJunction> |
getStreamJunctions() |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getTableDefinitionMap() |
ConcurrentMap<String,Table> |
getTableMap() |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getWindowDefinitionMap() |
ConcurrentMap<String,Window> |
getWindowMap() |
void |
setSiddhiAppRuntimeMap(ConcurrentMap<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
public SiddhiAppRuntimeBuilder(SiddhiAppContext siddhiAppContext)
public void defineStream(io.siddhi.query.api.definition.StreamDefinition streamDefinition)
public void defineTable(io.siddhi.query.api.definition.TableDefinition tableDefinition)
public void defineWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition)
public void defineTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition)
public void defineAggregation(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition)
public void addPartition(PartitionRuntime partitionRuntime)
public String addQuery(QueryRuntime queryRuntime)
public void defineFunction(io.siddhi.query.api.definition.FunctionDefinition functionDefinition)
public void setSiddhiAppRuntimeMap(ConcurrentMap<String,SiddhiAppRuntime> siddhiAppRuntimeMap)
public ConcurrentMap<String,StreamJunction> getStreamJunctions()
public ConcurrentMap<String,Table> getTableMap()
public ConcurrentMap<String,Window> getWindowMap()
public ConcurrentMap<String,AggregationRuntime> getAggregationMap()
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getStreamDefinitionMap()
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getTableDefinitionMap()
public ConcurrentMap<String,List<Source>> getSourceMap()
public ConcurrentMap<String,List<Sink>> getSinkMap()
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getWindowDefinitionMap()
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getAggregationDefinitionMap()
public LockSynchronizer getLockSynchronizer()
public SiddhiAppRuntime build()
Copyright © 2019. All rights reserved.