|
||||||||||
| 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 |
|---|
| 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 |
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.lang.String |
getBufferMemorySize()
Size of Memory in MB allocated to be used by the Resultset Management before disk buffering kicks in. |
java.util.Set<ServerConnection> |
getClientConnections()
This returns the active client connections that have been made to the DQP |
java.net.URL[] |
getCommonExtensionClasspath()
Get the user defined extension file classpath. |
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 |
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.net.URL |
getLogFile()
URL to Log file name |
java.lang.String |
getLogLevel()
Log Level |
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 |
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 |
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 |
| Constructor Detail |
|---|
public EmbeddedConfigurationService()
| Method Detail |
|---|
public java.net.URL getSystemVdb()
ConfigurationService
getSystemVdb in interface ConfigurationServiceConfigurationService.getSystemVdb()public java.util.Properties getSystemProperties()
ConfigurationService
getSystemProperties in interface ConfigurationServiceConfigurationService.getSystemProperties()
public void setSystemProperty(java.lang.String key,
java.lang.String value)
throws MetaMatrixComponentException
ConfigurationService
setSystemProperty in interface ConfigurationServiceMetaMatrixComponentExceptionConfigurationService.setSystemProperty(java.lang.String, java.lang.String)
public void updateSystemProperties(java.util.Properties properties)
throws MetaMatrixComponentException
ConfigurationService
updateSystemProperties in interface ConfigurationServiceproperties - The properties to set.
MetaMatrixComponentExceptionConfigurationService.updateSystemProperties(java.util.Properties)
public ConfigurationModelContainer getSystemConfiguration()
throws MetaMatrixComponentException
ConfigurationService
getSystemConfiguration in interface ConfigurationServiceMetaMatrixComponentExceptionConfigurationService.getSystemConfiguration()public java.net.URL getConfigFile()
ConfigurationService
getConfigFile in interface ConfigurationServiceConfigurationService.getConfigFile()public java.net.URL getUDFFile()
ConfigurationService
getUDFFile in interface ConfigurationServiceConfigurationService.getUDFFile()public java.net.URL[] getCommonExtensionClasspath()
ConfigurationService
getCommonExtensionClasspath in interface ConfigurationServiceConfigurationService.getCommonExtensionClasspath()public java.net.URL getLogFile()
ConfigurationService
getLogFile in interface ConfigurationServiceConfigurationService.getLogFile()public java.lang.String getLogLevel()
ConfigurationService
getLogLevel in interface ConfigurationServiceConfigurationService.getLogLevel()
public java.util.List<VDBArchive> getVDBs()
throws MetaMatrixComponentException
ConfigurationService
getVDBs in interface ConfigurationServiceVDBArchive
MetaMatrixComponentExceptionConfigurationService.getVDBs()
public VDBArchive getVDB(java.lang.String vdbName,
java.lang.String vdbVersion)
throws MetaMatrixComponentException
ConfigurationService
getVDB in interface ConfigurationServicevdbName - - Name of the VDB
MetaMatrixComponentExceptionConfigurationService.getVDB(java.lang.String, java.lang.String)
public void saveVDB(VDBArchive srcVdb,
java.lang.String version)
throws MetaMatrixComponentException
ConfigurationService
saveVDB in interface ConfigurationServicesrcVdb - - VDB to be savedversion - - Version to be saved as; when used text "NEXT_VDB_VERSION" as version
save as the next available version.
MetaMatrixComponentExceptioncom.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 ConfigurationServicevdb - - vdb to be addedreplaceBindings - - flag which specifies action to be taken in case there are conflicts in
connector bindings.
MetaMatrixComponentExceptioncom.metamatrix.dqp.service.ConfigurationService#addVDB(com.metamatrix.common.vdb.api.VDBDefn, boolean)
public void deleteVDB(VDBArchive vdb)
throws MetaMatrixComponentException
ConfigurationService
deleteVDB in interface ConfigurationServiceMetaMatrixComponentExceptioncom.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 ConfigurationServicevdbName - - Name of the VDBversion - - version of the VDBmodelName - - Model Namebindings - - bindings to be assigned
MetaMatrixComponentExceptionConfigurationService.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 ConfigurationServiceConnectorBinding
MetaMatrixComponentExceptionConfigurationService.getConnectorBindings()
public ConnectorBinding getConnectorBinding(java.lang.String deployedBindingName)
throws MetaMatrixComponentException
ConfigurationService
getConnectorBinding in interface ConfigurationServicedeployedBindingName - - Connector Binding Name
MetaMatrixComponentExceptionConfigurationService.getConnectorBinding(java.lang.String)public java.util.Properties getDefaultProperties(ConnectorBinding binding)
getDefaultProperties in interface ConfigurationServicebinding -
public ConnectorBinding addConnectorBinding(java.lang.String deployedBindingName,
ConnectorBinding binding,
boolean replace)
throws MetaMatrixComponentException
ConfigurationService
addConnectorBinding in interface ConfigurationServicedeployedBindingName - - Connector Binding Namebinding - - Connector binding to Addreplace - - flag to replace in case a duplicate found.
MetaMatrixComponentExceptionConfigurationService.addConnectorBinding(java.lang.String, com.metamatrix.common.config.api.ConnectorBinding, boolean)
public ConnectorBinding updateConnectorBinding(ConnectorBinding binding)
throws MetaMatrixComponentException
ConfigurationService
updateConnectorBinding in interface ConfigurationServicebinding - - Connector Binding to be modified
MetaMatrixComponentExceptionConfigurationService.updateConnectorBinding(com.metamatrix.common.config.api.ConnectorBinding)
public void deleteConnectorBinding(java.lang.String deployedConnectorBindingName)
throws MetaMatrixComponentException
ConfigurationService
deleteConnectorBinding in interface ConfigurationServicedeployedConnectorBindingName - - Connector Binding Name
MetaMatrixComponentExceptionConfigurationService.deleteConnectorBinding(java.lang.String)
public java.util.List getConnectorTypes()
throws MetaMatrixComponentException
ConfigurationService
getConnectorTypes in interface ConfigurationServiceComponentType
MetaMatrixComponentExceptionConfigurationService.getConnectorTypes()public java.net.URL getExtensionPath()
ConfigurationService
getExtensionPath in interface ConfigurationServiceConfigurationService.getExtensionPath()public boolean useExtensionClasspath()
ConfigurationService
useExtensionClasspath in interface ConfigurationServiceConfigurationService.useExtensionClasspath()
public ExtensionModule getExtensionModule(java.lang.String extModuleName)
throws MetaMatrixComponentException
ConfigurationService
getExtensionModule in interface ConfigurationServiceextModuleName - - Module name
MetaMatrixComponentExceptionConfigurationService.getExtensionModule(java.lang.String)
public java.util.List getExtensionModules()
throws MetaMatrixComponentException
ConfigurationService
getExtensionModules in interface ConfigurationServiceExtensionModule
MetaMatrixComponentExceptionConfigurationService.getExtensionModules()
public void saveExtensionModule(ExtensionModule extModule)
throws MetaMatrixComponentException
ConfigurationService
saveExtensionModule in interface ConfigurationServiceMetaMatrixComponentExceptionConfigurationService.saveExtensionModule(com.metamatrix.common.config.api.ExtensionModule)
public void deleteExtensionModule(java.lang.String extModuleName)
throws MetaMatrixComponentException
ConfigurationService
deleteExtensionModule in interface ConfigurationServiceextModuleName - - extension module name
MetaMatrixComponentExceptionConfigurationService.deleteExtensionModule(java.lang.String)
public ConnectorBindingType getConnectorType(java.lang.String connectorType)
throws MetaMatrixComponentException
ConfigurationService
getConnectorType in interface ConfigurationServiceMetaMatrixComponentExceptioncom.metamatrix.dqp.service.ConfigurationService#getConnectorType(com.metamatrix.common.config.api.ComponentTypeID)
public void saveConnectorType(ConnectorBindingType type)
throws MetaMatrixComponentException
ConfigurationService
saveConnectorType in interface ConfigurationServiceMetaMatrixComponentExceptioncom.metamatrix.dqp.service.ConfigurationService#addConnectorType(com.metamatrix.common.config.api.ComponentType)
public void deleteConnectorType(java.lang.String deployedConnectorType)
throws MetaMatrixComponentException
ConfigurationService
deleteConnectorType in interface ConfigurationServicedeployedConnectorType - - Name of the connector Type
MetaMatrixComponentExceptionConfigurationService.deleteConnectorType(java.lang.String)
public void loadUDF()
throws MetaMatrixComponentException
loadUDF in interface ConfigurationServiceMetaMatrixComponentExceptionpublic void unloadUDF()
unloadUDF in interface ConfigurationService
public void initializeService(java.util.Properties properties)
throws ApplicationInitializationException
initializeService in class EmbeddedBaseDQPServiceApplicationInitializationExceptionEmbeddedBaseDQPService.initializeService(java.util.Properties)
public void startService(ApplicationEnvironment environment)
throws ApplicationLifecycleException
startService in class EmbeddedBaseDQPServiceApplicationLifecycleExceptionEmbeddedBaseDQPService.startService(com.metamatrix.common.application.ApplicationEnvironment)
public void stopService()
throws ApplicationLifecycleException
stopService in class EmbeddedBaseDQPServiceApplicationLifecycleExceptionEmbeddedBaseDQPService.stopService()public java.net.URL[] getVDBLocations()
getVDBLocations in interface ConfigurationServicepublic java.net.URL getEncryptionKeyStore()
ConfigurationService
getEncryptionKeyStore in interface ConfigurationServiceConfigurationService.getEncryptionKeyStore()public ServerConnectionListener getConnectionListener()
ConfigurationService
getConnectionListener in interface ConfigurationServiceConfigurationService.getConnectionListener()public java.util.Set<ServerConnection> getClientConnections()
ConfigurationService
getClientConnections in interface ConfigurationServiceConfigurationService.getClientConnections()
public boolean isFullyConfiguredVDB(VDBArchive vdb)
throws MetaMatrixComponentException
isFullyConfiguredVDB in interface ConfigurationServiceMetaMatrixComponentExceptionpublic void register(ConnectorBindingLifeCycleListener listener)
register in interface ConfigurationServicelistener - - lister objectpublic void register(VDBLifeCycleListener listener)
register in interface ConfigurationServicelistener - - lister objectpublic boolean useDiskBuffering()
useDiskBuffering in interface ConfigurationServicepublic java.io.File getDiskBufferDirectory()
getDiskBufferDirectory in interface ConfigurationServicepublic java.lang.String getBufferMemorySize()
getBufferMemorySize in interface ConfigurationServicepublic java.lang.String getInstanceIdenifier()
ConfigurationService
getInstanceIdenifier in interface ConfigurationServiceConfigurationService.getInstanceIdenifier()public java.lang.String getProcessorBatchSize()
ConfigurationService
getProcessorBatchSize in interface ConfigurationServicepublic java.lang.String getConnectorBatchSize()
ConfigurationService
getConnectorBatchSize in interface ConfigurationServicepublic void unregister(VDBLifeCycleListener listener)
unregister in interface ConfigurationServicepublic void unregister(ConnectorBindingLifeCycleListener listener)
unregister in interface ConfigurationService
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||