public class SiddhiAppRuntimeImpl extends Object implements SiddhiAppRuntime
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 |
---|---|
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.
|
Map<String,AggregationRuntime> |
getAggregationMap() |
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 onDemandQuery)
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.
|
TableInputHandler |
getTableInputHandler(String tableId) |
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 onDemandQuery) |
Event[] |
query(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
Deprecated.
|
Event[] |
query(String onDemandQuery) |
void |
removeCallback(QueryCallback callback) |
void |
removeCallback(StreamCallback streamCallback) |
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() |
public 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)
public String getName()
getName
in interface SiddhiAppRuntime
public Map<String,io.siddhi.query.api.definition.StreamDefinition> getStreamDefinitionMap()
getStreamDefinitionMap
in interface SiddhiAppRuntime
StreamDefinition
s.public Map<String,io.siddhi.query.api.definition.TableDefinition> getTableDefinitionMap()
getTableDefinitionMap
in interface SiddhiAppRuntime
TableDefinition
s.public Map<String,io.siddhi.query.api.definition.WindowDefinition> getWindowDefinitionMap()
getWindowDefinitionMap
in interface SiddhiAppRuntime
WindowDefinition
s.public Map<String,io.siddhi.query.api.definition.AggregationDefinition> getAggregationDefinitionMap()
getAggregationDefinitionMap
in interface SiddhiAppRuntime
AggregationDefinition
s.public Map<String,AggregationRuntime> getAggregationMap()
getAggregationMap
in interface SiddhiAppRuntime
public Set<String> getQueryNames()
getQueryNames
in interface SiddhiAppRuntime
public Map<String,Map<String,io.siddhi.query.api.definition.AbstractDefinition>> getPartitionedInnerStreamDefinitionMap()
getPartitionedInnerStreamDefinitionMap
in interface SiddhiAppRuntime
public void addCallback(String streamId, StreamCallback streamCallback)
addCallback
in interface SiddhiAppRuntime
public void addCallback(String queryName, QueryCallback callback)
addCallback
in interface SiddhiAppRuntime
public void removeCallback(StreamCallback streamCallback)
removeCallback
in interface SiddhiAppRuntime
public void removeCallback(QueryCallback callback)
removeCallback
in interface SiddhiAppRuntime
public Event[] query(String onDemandQuery)
query
in interface SiddhiAppRuntime
public Event[] query(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery)
query
in interface SiddhiAppRuntime
@Deprecated public Event[] query(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
query
in interface SiddhiAppRuntime
public io.siddhi.query.api.definition.Attribute[] getOnDemandQueryOutputAttributes(String onDemandQuery)
getOnDemandQueryOutputAttributes
in interface SiddhiAppRuntime
public io.siddhi.query.api.definition.Attribute[] getOnDemandQueryOutputAttributes(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery)
getOnDemandQueryOutputAttributes
in interface SiddhiAppRuntime
@Deprecated public io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(String onDemandQuery)
getStoreQueryOutputAttributes
in interface SiddhiAppRuntime
@Deprecated public io.siddhi.query.api.definition.Attribute[] getStoreQueryOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery)
getStoreQueryOutputAttributes
in interface SiddhiAppRuntime
public InputHandler getInputHandler(String streamId)
getInputHandler
in interface SiddhiAppRuntime
public TableInputHandler getTableInputHandler(String tableId)
getTableInputHandler
in interface SiddhiAppRuntime
public Collection<List<Source>> getSources()
getSources
in interface SiddhiAppRuntime
public Collection<List<Sink>> getSinks()
getSinks
in interface SiddhiAppRuntime
public Collection<Table> getTables()
getTables
in interface SiddhiAppRuntime
public Collection<Window> getWindows()
getWindows
in interface SiddhiAppRuntime
public Collection<Trigger> getTiggers()
getTiggers
in interface SiddhiAppRuntime
public void start()
start
in interface SiddhiAppRuntime
public void startWithoutSources()
startWithoutSources
in interface SiddhiAppRuntime
public void setPurgingEnabled(boolean purgingEnabled)
setPurgingEnabled
in interface SiddhiAppRuntime
public void startSources()
startSources
in interface SiddhiAppRuntime
public void shutdown()
shutdown
in interface SiddhiAppRuntime
public SiddhiDebugger debug()
debug
in interface SiddhiAppRuntime
public PersistenceReference persist()
persist
in interface SiddhiAppRuntime
public byte[] snapshot()
snapshot
in interface SiddhiAppRuntime
public void restore(byte[] snapshot) throws CannotRestoreSiddhiAppStateException
restore
in interface SiddhiAppRuntime
CannotRestoreSiddhiAppStateException
public void restoreRevision(String revision) throws CannotRestoreSiddhiAppStateException
restoreRevision
in interface SiddhiAppRuntime
CannotRestoreSiddhiAppStateException
public String restoreLastRevision() throws CannotRestoreSiddhiAppStateException
restoreLastRevision
in interface SiddhiAppRuntime
CannotRestoreSiddhiAppStateException
public void clearAllRevisions() throws CannotClearSiddhiAppStateException
clearAllRevisions
in interface SiddhiAppRuntime
CannotClearSiddhiAppStateException
public void handleExceptionWith(com.lmax.disruptor.ExceptionHandler<Object> exceptionHandler)
handleExceptionWith
in interface SiddhiAppRuntime
public void handleRuntimeExceptionWith(ExceptionListener exceptionListener)
handleRuntimeExceptionWith
in interface SiddhiAppRuntime
public io.siddhi.query.api.SiddhiApp getSiddhiApp()
getSiddhiApp
in interface SiddhiAppRuntime
public Collection<QueryRuntime> getQueries()
getQueries
in interface SiddhiAppRuntime
public Collection<PartitionRuntime> getPartitions()
getPartitions
in interface SiddhiAppRuntime
public Level getStatisticsLevel()
getStatisticsLevel
in interface SiddhiAppRuntime
public void setStatisticsLevel(Level level)
setStatisticsLevel
in interface SiddhiAppRuntime
level
- whether statistics is OFF, BASIC or DETAILpublic void enablePlayBack(boolean playBackEnabled, Long idleTime, Long incrementInMilliseconds)
enablePlayBack
in interface SiddhiAppRuntime
playBackEnabled
- whether playback is enabled or notidleTime
- incrementInMilliseconds
- Copyright © 2021. All rights reserved.