public class SiddhiAppRuntime extends Object
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 |
addCallback(String queryName,
QueryCallback callback) |
void |
addCallback(String streamId,
StreamCallback streamCallback) |
void |
clearAllRevisions() |
SiddhiDebugger |
debug() |
void |
enablePlayBack(boolean playBackEnabled,
Long idleTime,
Long incrementInMilliseconds)
To enable and disable Siddhi App playback mode on runtime along with optional parameters.
|
void |
enableStats(boolean statsEnabled)
To enable and disable Siddhi App statistics on runtime.
|
Map<String,io.siddhi.query.api.definition.AggregationDefinition> |
getAggregationDefinitionMap()
Get the aggregation definition map.
|
InputHandler |
getInputHandler(String streamId) |
String |
getName() |
Map<String,Map<String,io.siddhi.query.api.definition.AbstractDefinition>> |
getPartitionedInnerStreamDefinitionMap() |
Set<String> |
getQueryNames()
Get the names of the available queries.
|
Collection<List<Sink>> |
getSinks() |
Collection<List<Source>> |
getSources() |
io.siddhi.query.api.definition.Attribute[] |
getStoreQueryOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery) |
io.siddhi.query.api.definition.Attribute[] |
getStoreQueryOutputAttributes(String storeQuery) |
Map<String,io.siddhi.query.api.definition.StreamDefinition> |
getStreamDefinitionMap()
Get the stream definition map.
|
Map<String,io.siddhi.query.api.definition.TableDefinition> |
getTableDefinitionMap()
Get the table definition map.
|
Collection<Table> |
getTables() |
Map<String,io.siddhi.query.api.definition.WindowDefinition> |
getWindowDefinitionMap()
Get the window definition map.
|
void |
handleExceptionWith(com.lmax.disruptor.ExceptionHandler<Object> exceptionHandler) |
void |
handleRuntimeExceptionWith(ExceptionListener exceptionListener) |
boolean |
isStatsEnabled()
Method to check whether the Siddhi App statistics are enabled or not.
|
PersistenceReference |
persist() |
Event[] |
query(io.siddhi.query.api.execution.query.StoreQuery storeQuery) |
Event[] |
query(String storeQuery) |
void |
restore(byte[] snapshot) |
String |
restoreLastRevision() |
void |
restoreRevision(String revision) |
void |
setPurgingEnabled(boolean purgingEnabled) |
void |
shutdown() |
byte[] |
snapshot() |
void |
start() |
void |
startSources() |
void |
startWithoutSources() |
public 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)
public String getName()
public Map<String,io.siddhi.query.api.definition.StreamDefinition> getStreamDefinitionMap()
StreamDefinition
s.public Map<String,io.siddhi.query.api.definition.TableDefinition> getTableDefinitionMap()
TableDefinition
s.public Map<String,io.siddhi.query.api.definition.WindowDefinition> getWindowDefinitionMap()
WindowDefinition
s.public Map<String,io.siddhi.query.api.definition.AggregationDefinition> getAggregationDefinitionMap()
AggregationDefinition
s.public Set<String> getQueryNames()
public Map<String,Map<String,io.siddhi.query.api.definition.AbstractDefinition>> getPartitionedInnerStreamDefinitionMap()
public void addCallback(String streamId, StreamCallback streamCallback)
public void addCallback(String queryName, QueryCallback callback)
public Event[] query(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
public io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(String storeQuery)
public io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
public InputHandler getInputHandler(String streamId)
public Collection<List<Source>> getSources()
public Collection<List<Sink>> getSinks()
public Collection<Table> getTables()
public void start()
public void startWithoutSources()
public void setPurgingEnabled(boolean purgingEnabled)
public void startSources()
public void shutdown()
public SiddhiDebugger debug()
public PersistenceReference persist()
public byte[] snapshot()
public void restore(byte[] snapshot) throws CannotRestoreSiddhiAppStateException
public void restoreRevision(String revision) throws CannotRestoreSiddhiAppStateException
public String restoreLastRevision() throws CannotRestoreSiddhiAppStateException
public void clearAllRevisions() throws CannotClearSiddhiAppStateException
public void handleExceptionWith(com.lmax.disruptor.ExceptionHandler<Object> exceptionHandler)
public void handleRuntimeExceptionWith(ExceptionListener exceptionListener)
public boolean isStatsEnabled()
public void enableStats(boolean statsEnabled)
statsEnabled
- whether statistics is enabled or notpublic void enablePlayBack(boolean playBackEnabled, Long idleTime, Long incrementInMilliseconds)
playBackEnabled
- whether playback is enabled or notidleTime
- incrementInMilliseconds
- Copyright © 2019. All rights reserved.