public class SiddhiManager extends Object
Constructor and Description |
---|
SiddhiManager()
Creates a Siddhi Manager instance with default
SiddhiContext . |
Modifier and Type | Method and Description |
---|---|
SiddhiAppRuntime |
createSiddhiAppRuntime(io.siddhi.query.api.SiddhiApp siddhiApp) |
SiddhiAppRuntime |
createSiddhiAppRuntime(String siddhiApp) |
Map<String,Class> |
getExtensions()
Method used to get the extensions registered in the siddhi manager.
|
String |
getLastRevision(String siddhiAppName)
Method to retrieve last revision for siddhi app by providing the name.
|
SiddhiAppRuntime |
getSiddhiAppRuntime(String siddhiAppName)
Method to retrieve already submitted siddhi app by providing the name.
|
ConcurrentMap<String,SiddhiAppRuntime> |
getSiddhiAppRuntimeMap()
Method used to get all SiddhiAppRuntimes
|
void |
persist()
Method used persist state of current Siddhi Manager instance.
|
void |
removeExtension(String name)
Method used to remove the extensions registered in the siddhi manager.
|
void |
restoreLastState()
Method used to restore state of Current Siddhi Manager instance.
|
void |
setConfigManager(ConfigManager configManager)
Method to set configManager for the Siddhi Manager instance.
|
void |
setDataSource(String dataSourceName,
DataSource dataSource)
Method used to add Carbon DataSources to Siddhi Manager to utilize them for event tables.
|
void |
setExtension(String name,
Class clazz)
Method used to register extensions to the Siddhi Manager.
|
void |
setIncrementalPersistenceStore(IncrementalPersistenceStore incrementalPersistenceStore) |
void |
setPersistenceStore(PersistenceStore persistenceStore)
Method to set persistence for the Siddhi Manager instance.
|
void |
setRecordTableHandlerManager(RecordTableHandlerManager recordTableHandlerManager)
Method to set record table handler manager that would create record table handlers for each record table
|
void |
setSinkHandlerManager(SinkHandlerManager sinkHandlerManager)
Method to set sink handler manager that would create sink handlers for each sink
|
void |
setSourceHandlerManager(SourceHandlerManager sourceHandlerManager)
Method to set source handler manager that would create source handlers for each source
|
void |
setStatisticsConfiguration(StatisticsConfiguration statisticsConfiguration)
Method to integrate Carbon Metrics into Siddhi
|
void |
shutdown()
Method to shutdown Siddhi Manager
|
void |
validateSiddhiApp(io.siddhi.query.api.SiddhiApp siddhiApp) |
void |
validateSiddhiApp(String siddhiApp) |
public SiddhiManager()
SiddhiContext
. This is the only method to create a new
Siddhi Manager instance which is the main interface when you use Siddhi as a library.public SiddhiAppRuntime createSiddhiAppRuntime(io.siddhi.query.api.SiddhiApp siddhiApp)
public SiddhiAppRuntime createSiddhiAppRuntime(String siddhiApp)
public SiddhiAppRuntime getSiddhiAppRuntime(String siddhiAppName)
siddhiAppName
- Name of the required Siddhi apppublic void validateSiddhiApp(io.siddhi.query.api.SiddhiApp siddhiApp)
public void validateSiddhiApp(String siddhiApp)
public void setPersistenceStore(PersistenceStore persistenceStore)
InMemoryPersistenceStore
is the default persistence store
implementation users can utilize.persistenceStore
- Persistence Store implementation to be used.public void setSinkHandlerManager(SinkHandlerManager sinkHandlerManager)
sinkHandlerManager
- Sink Handler Manager Implementation to be used.public void setSourceHandlerManager(SourceHandlerManager sourceHandlerManager)
sourceHandlerManager
- Source Handler Manager Implementation to be used.public void setRecordTableHandlerManager(RecordTableHandlerManager recordTableHandlerManager)
recordTableHandlerManager
- Record Table Handler Manager Implementation to be used.public void setConfigManager(ConfigManager configManager)
configManager
- Config Manager implementation to be used.public void setExtension(String name, Class clazz)
name
- Name of the extension as mentioned in the annotation.clazz
- Class name of the implementationpublic Map<String,Class> getExtensions()
public void removeExtension(String name)
name
- Name of the extension as given in the annotation.public void setDataSource(String dataSourceName, DataSource dataSource)
dataSourceName
- Name of the DataSourcedataSource
- Object representing DataSourcepublic void setStatisticsConfiguration(StatisticsConfiguration statisticsConfiguration)
statisticsConfiguration
- statistics configurationpublic ConcurrentMap<String,SiddhiAppRuntime> getSiddhiAppRuntimeMap()
public void shutdown()
public void persist()
public void restoreLastState()
public String getLastRevision(String siddhiAppName)
siddhiAppName
- Name of the required Siddhi apppublic void setIncrementalPersistenceStore(IncrementalPersistenceStore incrementalPersistenceStore)
Copyright © 2019. All rights reserved.