public interface SiddhiAppRuntime
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.
|
Map<String,io.siddhi.query.api.definition.AggregationDefinition> |
getAggregationDefinitionMap()
Get the aggregation definition map.
|
InputHandler |
getInputHandler(String streamId) |
String |
getName() |
io.siddhi.query.api.definition.Attribute[] |
getOnDemandQueryOutputAttributes(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery) |
io.siddhi.query.api.definition.Attribute[] |
getOnDemandQueryOutputAttributes(String onDemandQuery) |
Map<String,Map<String,io.siddhi.query.api.definition.AbstractDefinition>> |
getPartitionedInnerStreamDefinitionMap() |
Collection<PartitionRuntime> |
getPartitions() |
Collection<QueryRuntime> |
getQueries() |
Set<String> |
getQueryNames()
Get the names of the available queries.
|
io.siddhi.query.api.SiddhiApp |
getSiddhiApp() |
Collection<List<Sink>> |
getSinks() |
Collection<List<Source>> |
getSources() |
Level |
getStatisticsLevel()
Method to check the Siddhi App statistics level enabled.
|
io.siddhi.query.api.definition.Attribute[] |
getStoreQueryOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
Deprecated.
|
io.siddhi.query.api.definition.Attribute[] |
getStoreQueryOutputAttributes(String storeQuery)
Deprecated.
|
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() |
Collection<Trigger> |
getTiggers() |
Map<String,io.siddhi.query.api.definition.WindowDefinition> |
getWindowDefinitionMap()
Get the window definition map.
|
Collection<Window> |
getWindows() |
void |
handleExceptionWith(com.lmax.disruptor.ExceptionHandler<Object> exceptionHandler) |
void |
handleRuntimeExceptionWith(ExceptionListener exceptionListener) |
PersistenceReference |
persist() |
Event[] |
query(io.siddhi.query.api.execution.query.OnDemandQuery storeQuery) |
Event[] |
query(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
Deprecated.
|
Event[] |
query(String onDemandQuery) |
void |
restore(byte[] snapshot) |
String |
restoreLastRevision() |
void |
restoreRevision(String revision) |
void |
setPurgingEnabled(boolean purgingEnabled) |
void |
setStatisticsLevel(Level level)
To enable, disable and change Siddhi App statistics level on runtime.
|
void |
shutdown() |
byte[] |
snapshot() |
void |
start() |
void |
startSources() |
void |
startWithoutSources() |
String getName()
io.siddhi.query.api.SiddhiApp getSiddhiApp()
Map<String,io.siddhi.query.api.definition.StreamDefinition> getStreamDefinitionMap()
StreamDefinition
s.Map<String,io.siddhi.query.api.definition.TableDefinition> getTableDefinitionMap()
TableDefinition
s.Map<String,io.siddhi.query.api.definition.WindowDefinition> getWindowDefinitionMap()
WindowDefinition
s.Map<String,io.siddhi.query.api.definition.AggregationDefinition> getAggregationDefinitionMap()
AggregationDefinition
s.Set<String> getQueryNames()
Map<String,Map<String,io.siddhi.query.api.definition.AbstractDefinition>> getPartitionedInnerStreamDefinitionMap()
Collection<List<Source>> getSources()
Collection<List<Sink>> getSinks()
Collection<Table> getTables()
Collection<Window> getWindows()
Collection<Trigger> getTiggers()
Collection<QueryRuntime> getQueries()
Collection<PartitionRuntime> getPartitions()
void addCallback(String streamId, StreamCallback streamCallback)
void addCallback(String queryName, QueryCallback callback)
@Deprecated Event[] query(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
Event[] query(io.siddhi.query.api.execution.query.OnDemandQuery storeQuery)
@Deprecated io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(String storeQuery)
@Deprecated io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
io.siddhi.query.api.definition.Attribute[] getOnDemandQueryOutputAttributes(String onDemandQuery)
io.siddhi.query.api.definition.Attribute[] getOnDemandQueryOutputAttributes(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery)
InputHandler getInputHandler(String streamId)
void setPurgingEnabled(boolean purgingEnabled)
void start()
void startWithoutSources()
void startSources()
void shutdown()
SiddhiDebugger debug()
PersistenceReference persist()
byte[] snapshot()
void restore(byte[] snapshot) throws CannotRestoreSiddhiAppStateException
void restoreRevision(String revision) throws CannotRestoreSiddhiAppStateException
String restoreLastRevision() throws CannotRestoreSiddhiAppStateException
void clearAllRevisions() throws CannotClearSiddhiAppStateException
void handleExceptionWith(com.lmax.disruptor.ExceptionHandler<Object> exceptionHandler)
void handleRuntimeExceptionWith(ExceptionListener exceptionListener)
Level getStatisticsLevel()
void setStatisticsLevel(Level level)
level
- whether statistics is OFF, BASIC or DETAILCopyright © 2019. All rights reserved.