|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.metamatrix.dqp.embedded.services.EmbeddedBaseDQPService
com.metamatrix.dqp.embedded.services.EmbeddedConfigurationService
public class EmbeddedConfigurationService
A File based configuration service implementation Implementation notes - While loading the VDBs also keep track of Connector Bindings loaded separately - While loading the VDBs also keep track of Connector types loaded separately - The above list also should contain the list from server config file. - Onlu used get, save, delete of any configuration on public api
Field Summary | |
---|---|
static java.lang.String |
PROPERTIES_URL
|
Fields inherited from class com.metamatrix.dqp.embedded.services.EmbeddedBaseDQPService |
---|
SYSTEM_PHYSICAL_MODEL_NAME |
Fields inherited from interface com.metamatrix.dqp.service.ConfigurationService |
---|
NEXT_VDB_VERSION, USER_DEFINED_FUNCTION_MODEL |
Constructor Summary | |
---|---|
EmbeddedConfigurationService()
|
Method Summary | |
---|---|
ConnectorBinding |
addConnectorBinding(java.lang.String deployedBindingName,
ConnectorBinding binding,
boolean replace)
Add the connector binding to the persistent store |
VDBArchive |
addVDB(VDBArchive vdb,
boolean replaceBindings)
Add the VDB to the configuration |
void |
assignConnectorBinding(java.lang.String vdbName,
java.lang.String version,
java.lang.String modelName,
ConnectorBinding[] bindings)
Assign a connector binding to the Model |
void |
clearClassLoaderCache()
|
void |
deleteConnectorBinding(java.lang.String deployedConnectorBindingName)
Delete the connector binding from the persistent store |
void |
deleteConnectorType(java.lang.String deployedConnectorType)
Delete the Given component type to the persistent store |
void |
deleteExtensionModule(java.lang.String extModuleName)
Delete the extension module from the configuration with name supplied |
void |
deleteVDB(VDBArchive vdb)
Delete the VDB from the underlying persistent mechanism used by this configuration service |
java.net.URL |
getBootStrapURL()
|
java.lang.String |
getBufferMemorySize()
Size of Memory in MB allocated to be used by the Resultset Management before disk buffering kicks in. |
AbstractClassLoaderManager |
getClassLoaderManager()
|
java.util.Set<ServerConnection> |
getClientConnections()
This returns the active client connections that have been made to the DQP |
java.lang.ClassLoader |
getCommonClassLoader(java.lang.String urls)
Return the common class loader with the given urls appended |
java.net.URL |
getConfigFile()
Gets the reference URL to the Configuration File for the DQP. |
ServerConnectionListener |
getConnectionListener()
Client Connection Listener object for the service; This will get notifications about the connections currently available to DQP. |
java.lang.String |
getConnectorBatchSize()
Gets the connector batch size |
ConnectorBinding |
getConnectorBinding(java.lang.String deployedBindingName)
get the connector binding from the persistent store |
java.util.List |
getConnectorBindings()
Get the list of connector bindings available in the configuration. |
ConnectorBindingType |
getConnectorType(java.lang.String connectorType)
Get Component type for the given id |
java.util.List |
getConnectorTypes()
Get list of all the connector types available in the System. |
java.util.Properties |
getDefaultProperties(ConnectorBinding binding)
Get the default properties for the connector binding given. |
java.io.File |
getDiskBufferDirectory()
Get the directory to use for the disk buffering |
java.net.URL |
getEncryptionKeyStore()
Get the URL to the "metamatrixpki.keystore" file |
ExtensionModule |
getExtensionModule(java.lang.String extModuleName)
Get the extension module by the given identifier |
java.util.List<ExtensionModule> |
getExtensionModules()
Get the list of extension modules available in the store |
java.net.URL[] |
getExtensionPath()
Retun the context class path to be used by all the extension modules to use. |
java.lang.String |
getInstanceIdenifier()
Return some identifier which uniquely identifies the DQP. |
java.lang.String |
getLogLevel()
Log Level |
java.lang.ClassLoader |
getPostDelegationClassLoader(java.lang.String urls)
Return a distinct post delgation class loader - which may be cached. |
java.lang.String |
getProcessorBatchSize()
Gets the processor batch size |
ConfigurationModelContainer |
getSystemConfiguration()
Get the system Configuration object loaded from the configuration object, this is currently only needed to support the exportConfiguration admin call. |
java.util.Properties |
getSystemProperties()
Get DQP properties |
java.net.URL |
getSystemVdb()
Get the VDB contents for the "System.VDB" |
java.net.URL |
getUDFFile()
Get the user defined functions file name |
VDBArchive |
getVDB(java.lang.String vdbName,
java.lang.String vdbVersion)
Get the list of VDB files available with the Configuration Service, this includes all status (active, inactive) |
java.net.URL[] |
getVDBLocations()
Get path(s) for VDB(s) that are availble from the configuration to the DQP engine. |
java.util.List<VDBArchive> |
getVDBs()
Get a list of available VDBS from the configuration |
java.io.File |
getWorkDir()
|
void |
initializeService(java.util.Properties properties)
|
boolean |
isFullyConfiguredVDB(VDBArchive vdb)
|
void |
loadUDF()
Load the User defined functions file |
void |
register(ConnectorBindingLifeCycleListener listener)
Register a listener for the VDB life cycle events, and get notified for when vdb is loded and unloaded |
void |
register(VDBLifeCycleListener listener)
Register a listener for the VDB life cycle events, and get notified for when vdb is loded and unloaded |
void |
saveConnectorType(ConnectorBindingType type)
Add the Given component type to the persistent store |
void |
saveExtensionModule(ExtensionModule extModule)
Save the given extension module |
void |
saveVDB(VDBArchive srcVdb,
java.lang.String version)
Save the given vdb file into underlying persistent mechanism used by this configuration service |
void |
setBootStrapURL(java.net.URL bootStrapURL)
|
void |
setSystemProperty(java.lang.String key,
java.lang.String value)
Set System property (Contents of ServerConfig.xml file) |
void |
startService(ApplicationEnvironment environment)
|
void |
stopService()
|
void |
unloadUDF()
Unload the UDF file at the end of the DQP, because the same JVM could be used to load another DQP and we do want the static function library hanging on to old function libraries |
void |
unregister(ConnectorBindingLifeCycleListener listener)
|
void |
unregister(VDBLifeCycleListener listener)
|
ConnectorBinding |
updateConnectorBinding(ConnectorBinding binding)
Update the Connector Binding, the assumption here that we kept the name same |
void |
updateSystemProperties(java.util.Properties properties)
Set several System properties (Contents of ServerConfig.xml file). |
boolean |
useDiskBuffering()
Use disk for buffering for result set management during the processing |
boolean |
useExtensionClasspath()
Use the extension classpath defined in the connector bindins and load jars in different class loader or in the same class loader as calling code |
Methods inherited from class com.metamatrix.dqp.embedded.services.EmbeddedBaseDQPService |
---|
getConfigurationService, initialize, isStarted, isValidVDB, lookupService, start, stop, vdbId, vdbId |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.metamatrix.common.application.ApplicationService |
---|
initialize, start, stop |
Field Detail |
---|
public static final java.lang.String PROPERTIES_URL
Constructor Detail |
---|
public EmbeddedConfigurationService()
Method Detail |
---|
public java.net.URL getBootStrapURL()
public void setBootStrapURL(java.net.URL bootStrapURL)
public java.net.URL getSystemVdb()
ConfigurationService
getSystemVdb
in interface ConfigurationService
ConfigurationService.getSystemVdb()
public java.util.Properties getSystemProperties()
ConfigurationService
getSystemProperties
in interface ConfigurationService
ConfigurationService.getSystemProperties()
public void setSystemProperty(java.lang.String key, java.lang.String value) throws MetaMatrixComponentException
ConfigurationService
setSystemProperty
in interface ConfigurationService
MetaMatrixComponentException
ConfigurationService.setSystemProperty(java.lang.String, java.lang.String)
public void updateSystemProperties(java.util.Properties properties) throws MetaMatrixComponentException
ConfigurationService
updateSystemProperties
in interface ConfigurationService
properties
- The properties to set.
MetaMatrixComponentException
ConfigurationService.updateSystemProperties(java.util.Properties)
public ConfigurationModelContainer getSystemConfiguration() throws MetaMatrixComponentException
ConfigurationService
getSystemConfiguration
in interface ConfigurationService
MetaMatrixComponentException
ConfigurationService.getSystemConfiguration()
public java.net.URL getConfigFile()
ConfigurationService
getConfigFile
in interface ConfigurationService
ConfigurationService.getConfigFile()
public java.net.URL getUDFFile()
ConfigurationService
getUDFFile
in interface ConfigurationService
ConfigurationService.getUDFFile()
public java.lang.ClassLoader getCommonClassLoader(java.lang.String urls)
ClassLoaderManager
getCommonClassLoader
in interface ClassLoaderManager
public java.lang.ClassLoader getPostDelegationClassLoader(java.lang.String urls)
ClassLoaderManager
getPostDelegationClassLoader
in interface ClassLoaderManager
public AbstractClassLoaderManager getClassLoaderManager()
public java.lang.String getLogLevel()
ConfigurationService
getLogLevel
in interface ConfigurationService
ConfigurationService.getLogLevel()
public java.util.List<VDBArchive> getVDBs() throws MetaMatrixComponentException
ConfigurationService
getVDBs
in interface ConfigurationService
VDBArchive
MetaMatrixComponentException
ConfigurationService.getVDBs()
public VDBArchive getVDB(java.lang.String vdbName, java.lang.String vdbVersion) throws MetaMatrixComponentException
ConfigurationService
getVDB
in interface ConfigurationService
vdbName
- - Name of the VDB
MetaMatrixComponentException
ConfigurationService.getVDB(java.lang.String, java.lang.String)
public void saveVDB(VDBArchive srcVdb, java.lang.String version) throws MetaMatrixComponentException
ConfigurationService
saveVDB
in interface ConfigurationService
srcVdb
- - VDB to be savedversion
- - Version to be saved as; when used text "NEXT_VDB_VERSION" as version
save as the next available version.
MetaMatrixComponentException
com.metamatrix.dqp.service.ConfigurationService#saveVDB(com.metamatrix.metadata.runtime.admin.vdb.VDBDefn)
public VDBArchive addVDB(VDBArchive vdb, boolean replaceBindings) throws MetaMatrixComponentException
ConfigurationService
addVDB
in interface ConfigurationService
vdb
- - vdb to be addedreplaceBindings
- - flag which specifies action to be taken in case there are conflicts in
connector bindings.
MetaMatrixComponentException
com.metamatrix.dqp.service.ConfigurationService#addVDB(com.metamatrix.common.vdb.api.VDBDefn, boolean)
public void deleteVDB(VDBArchive vdb) throws MetaMatrixComponentException
ConfigurationService
deleteVDB
in interface ConfigurationService
MetaMatrixComponentException
com.metamatrix.dqp.service.ConfigurationService#deleteVDB(java.lang.String, java.lang.String)
public void assignConnectorBinding(java.lang.String vdbName, java.lang.String version, java.lang.String modelName, ConnectorBinding[] bindings) throws MetaMatrixComponentException
ConfigurationService
assignConnectorBinding
in interface ConfigurationService
vdbName
- - Name of the VDBversion
- - version of the VDBmodelName
- - Model Namebindings
- - bindings to be assigned
MetaMatrixComponentException
ConfigurationService.assignConnectorBinding(java.lang.String, java.lang.String, java.lang.String, com.metamatrix.common.config.api.ConnectorBinding[])
public java.util.List getConnectorBindings() throws MetaMatrixComponentException
ConfigurationService
getConnectorBindings
in interface ConfigurationService
ConnectorBinding
MetaMatrixComponentException
ConfigurationService.getConnectorBindings()
public ConnectorBinding getConnectorBinding(java.lang.String deployedBindingName) throws MetaMatrixComponentException
ConfigurationService
getConnectorBinding
in interface ConfigurationService
deployedBindingName
- - Connector Binding Name
MetaMatrixComponentException
ConfigurationService.getConnectorBinding(java.lang.String)
public java.util.Properties getDefaultProperties(ConnectorBinding binding)
getDefaultProperties
in interface ConfigurationService
binding
-
public ConnectorBinding addConnectorBinding(java.lang.String deployedBindingName, ConnectorBinding binding, boolean replace) throws MetaMatrixComponentException
ConfigurationService
addConnectorBinding
in interface ConfigurationService
deployedBindingName
- - Connector Binding Namebinding
- - Connector binding to Addreplace
- - flag to replace in case a duplicate found.
MetaMatrixComponentException
ConfigurationService.addConnectorBinding(java.lang.String, com.metamatrix.common.config.api.ConnectorBinding, boolean)
public ConnectorBinding updateConnectorBinding(ConnectorBinding binding) throws MetaMatrixComponentException
ConfigurationService
updateConnectorBinding
in interface ConfigurationService
binding
- - Connector Binding to be modified
MetaMatrixComponentException
ConfigurationService.updateConnectorBinding(com.metamatrix.common.config.api.ConnectorBinding)
public void deleteConnectorBinding(java.lang.String deployedConnectorBindingName) throws MetaMatrixComponentException
ConfigurationService
deleteConnectorBinding
in interface ConfigurationService
deployedConnectorBindingName
- - Connector Binding Name
MetaMatrixComponentException
ConfigurationService.deleteConnectorBinding(java.lang.String)
public java.util.List getConnectorTypes() throws MetaMatrixComponentException
ConfigurationService
getConnectorTypes
in interface ConfigurationService
ComponentType
MetaMatrixComponentException
ConfigurationService.getConnectorTypes()
public java.net.URL[] getExtensionPath()
ConfigurationService
getExtensionPath
in interface ConfigurationService
ConfigurationService.getExtensionPath()
public boolean useExtensionClasspath()
ConfigurationService
useExtensionClasspath
in interface ConfigurationService
ConfigurationService.useExtensionClasspath()
public ExtensionModule getExtensionModule(java.lang.String extModuleName) throws MetaMatrixComponentException
ConfigurationService
getExtensionModule
in interface ConfigurationService
extModuleName
- - Module name
MetaMatrixComponentException
ConfigurationService.getExtensionModule(java.lang.String)
public java.util.List<ExtensionModule> getExtensionModules() throws MetaMatrixComponentException
ConfigurationService
getExtensionModules
in interface ConfigurationService
ExtensionModule
MetaMatrixComponentException
ConfigurationService.getExtensionModules()
public void saveExtensionModule(ExtensionModule extModule) throws MetaMatrixComponentException
ConfigurationService
saveExtensionModule
in interface ConfigurationService
MetaMatrixComponentException
ConfigurationService.saveExtensionModule(com.metamatrix.common.config.api.ExtensionModule)
public void deleteExtensionModule(java.lang.String extModuleName) throws MetaMatrixComponentException
ConfigurationService
deleteExtensionModule
in interface ConfigurationService
extModuleName
- - extension module name
MetaMatrixComponentException
ConfigurationService.deleteExtensionModule(java.lang.String)
public ConnectorBindingType getConnectorType(java.lang.String connectorType) throws MetaMatrixComponentException
ConfigurationService
getConnectorType
in interface ConfigurationService
MetaMatrixComponentException
com.metamatrix.dqp.service.ConfigurationService#getConnectorType(com.metamatrix.common.config.api.ComponentTypeID)
public void saveConnectorType(ConnectorBindingType type) throws MetaMatrixComponentException
ConfigurationService
saveConnectorType
in interface ConfigurationService
MetaMatrixComponentException
com.metamatrix.dqp.service.ConfigurationService#addConnectorType(com.metamatrix.common.config.api.ComponentType)
public void deleteConnectorType(java.lang.String deployedConnectorType) throws MetaMatrixComponentException
ConfigurationService
deleteConnectorType
in interface ConfigurationService
deployedConnectorType
- - Name of the connector Type
MetaMatrixComponentException
ConfigurationService.deleteConnectorType(java.lang.String)
public void loadUDF() throws MetaMatrixComponentException
loadUDF
in interface ConfigurationService
MetaMatrixComponentException
public void unloadUDF()
unloadUDF
in interface ConfigurationService
public void initializeService(java.util.Properties properties) throws ApplicationInitializationException
initializeService
in class EmbeddedBaseDQPService
ApplicationInitializationException
EmbeddedBaseDQPService.initializeService(java.util.Properties)
public void startService(ApplicationEnvironment environment) throws ApplicationLifecycleException
startService
in class EmbeddedBaseDQPService
ApplicationLifecycleException
EmbeddedBaseDQPService.startService(com.metamatrix.common.application.ApplicationEnvironment)
public void stopService() throws ApplicationLifecycleException
stopService
in class EmbeddedBaseDQPService
ApplicationLifecycleException
EmbeddedBaseDQPService.stopService()
public java.net.URL[] getVDBLocations()
getVDBLocations
in interface ConfigurationService
public java.net.URL getEncryptionKeyStore()
ConfigurationService
getEncryptionKeyStore
in interface ConfigurationService
ConfigurationService.getEncryptionKeyStore()
public ServerConnectionListener getConnectionListener()
ConfigurationService
getConnectionListener
in interface ConfigurationService
ConfigurationService.getConnectionListener()
public java.util.Set<ServerConnection> getClientConnections()
ConfigurationService
getClientConnections
in interface ConfigurationService
ConfigurationService.getClientConnections()
public boolean isFullyConfiguredVDB(VDBArchive vdb) throws MetaMatrixComponentException
isFullyConfiguredVDB
in interface ConfigurationService
MetaMatrixComponentException
public void register(ConnectorBindingLifeCycleListener listener)
register
in interface ConfigurationService
listener
- - lister objectpublic void register(VDBLifeCycleListener listener)
register
in interface ConfigurationService
listener
- - lister objectpublic boolean useDiskBuffering()
useDiskBuffering
in interface ConfigurationService
public java.io.File getWorkDir()
public java.io.File getDiskBufferDirectory()
getDiskBufferDirectory
in interface ConfigurationService
public java.lang.String getBufferMemorySize()
getBufferMemorySize
in interface ConfigurationService
public java.lang.String getInstanceIdenifier()
ConfigurationService
getInstanceIdenifier
in interface ConfigurationService
ConfigurationService.getInstanceIdenifier()
public java.lang.String getProcessorBatchSize()
ConfigurationService
getProcessorBatchSize
in interface ConfigurationService
public java.lang.String getConnectorBatchSize()
ConfigurationService
getConnectorBatchSize
in interface ConfigurationService
public void unregister(VDBLifeCycleListener listener)
unregister
in interface ConfigurationService
public void unregister(ConnectorBindingLifeCycleListener listener)
unregister
in interface ConfigurationService
public void clearClassLoaderCache() throws MetaMatrixComponentException
clearClassLoaderCache
in interface ConfigurationService
MetaMatrixComponentException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |