|
||||||||||
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.EmbeddedDataService
public class EmbeddedDataService
A DataService implementation for the DQP.
Field Summary |
---|
Fields inherited from class com.metamatrix.dqp.embedded.services.EmbeddedBaseDQPService |
---|
SYSTEM_PHYSICAL_MODEL_NAME |
Constructor Summary | |
---|---|
EmbeddedDataService()
|
Method Summary | |
---|---|
void |
cancelRequest(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
void |
clearConnectorBindingCache(java.lang.String connectorBindingName)
|
void |
closeRequest(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
protected java.lang.String |
decryptProperty(java.lang.String value)
Decrypt the given property using the Crypto libraries. |
void |
executeRequest(AtomicRequestMessage request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connector,
ResultsReceiver<AtomicResultsMessage> resultListener)
Execute the given request on a Connector . |
SourceCapabilities |
getCapabilities(RequestMessage request,
org.teiid.dqp.internal.process.DQPWorkContext dqpWorkContext,
com.metamatrix.dqp.internal.datamgr.ConnectorID connector)
|
ConnectorBinding |
getConnectorBinding(java.lang.String deployedConnectorBindingName)
|
java.util.List |
getConnectorBindings()
|
java.lang.Boolean |
getConnectorBindingState(java.lang.String deployedConnectorBindingName)
|
java.util.Collection |
getConnectorBindingStatistics(java.lang.String connectorBindingName)
|
void |
initializeService(java.util.Properties props)
Initialize the service with the specified properties. |
protected boolean |
isMaskedProperty(java.lang.String propName,
ComponentType type)
Check to see if the property read is a masked/encoded property |
void |
requestBatch(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
com.metamatrix.dqp.internal.datamgr.ConnectorID |
selectConnector(java.lang.String deployedConnectorBindingName)
Select a connector to use for the given connector binding. |
void |
startConnectorBinding(java.lang.String deployedConnectorBindingName)
|
void |
startService(ApplicationEnvironment environment)
Start the service with the specified environment. |
void |
stopConnectorBinding(java.lang.String deployedConnectorBindingName)
|
void |
stopService()
Stop the service. |
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 EmbeddedDataService()
Method Detail |
---|
public com.metamatrix.dqp.internal.datamgr.ConnectorID selectConnector(java.lang.String deployedConnectorBindingName) throws MetaMatrixComponentException
selectConnector
in interface DataService
deployedConnectorBindingName
- Connector binding identifier
MetaMatrixComponentException
public void executeRequest(AtomicRequestMessage request, com.metamatrix.dqp.internal.datamgr.ConnectorID connector, ResultsReceiver<AtomicResultsMessage> resultListener) throws MetaMatrixComponentException
Connector
. The results are passed in to the
listener object.
executeRequest
in interface DataService
MetaMatrixComponentException
com.metamatrix.dqp.service.DataService#executeRequest(com.metamatrix.dqp.message.AtomicRequestMessage, com.metamatrix.dqp.internal.datamgr.ConnectorID, com.metamatrix.common.comm.api.MessageListener)
public void cancelRequest(AtomicRequestID request, com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId) throws MetaMatrixComponentException
cancelRequest
in interface DataService
MetaMatrixComponentException
public void closeRequest(AtomicRequestID request, com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId) throws MetaMatrixComponentException
closeRequest
in interface DataService
MetaMatrixComponentException
public void requestBatch(AtomicRequestID request, com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId) throws MetaMatrixComponentException
requestBatch
in interface DataService
MetaMatrixComponentException
public SourceCapabilities getCapabilities(RequestMessage request, org.teiid.dqp.internal.process.DQPWorkContext dqpWorkContext, com.metamatrix.dqp.internal.datamgr.ConnectorID connector) throws MetaMatrixComponentException
getCapabilities
in interface DataService
MetaMatrixComponentException
public java.util.Collection getConnectorBindingStatistics(java.lang.String connectorBindingName) throws MetaMatrixComponentException
getConnectorBindingStatistics
in interface DataService
MetaMatrixComponentException
DataService.getConnectorBindingStatistics(java.lang.String)
public void clearConnectorBindingCache(java.lang.String connectorBindingName) throws MetaMatrixComponentException
clearConnectorBindingCache
in interface DataService
MetaMatrixComponentException
DataService.clearConnectorBindingCache(java.lang.String)
public void startConnectorBinding(java.lang.String deployedConnectorBindingName) throws ApplicationLifecycleException, MetaMatrixComponentException
startConnectorBinding
in interface DataService
ApplicationLifecycleException
MetaMatrixComponentException
DataService.startConnectorBinding(java.lang.String)
public void stopConnectorBinding(java.lang.String deployedConnectorBindingName) throws ApplicationLifecycleException, MetaMatrixComponentException
stopConnectorBinding
in interface DataService
ApplicationLifecycleException
MetaMatrixComponentException
DataService.stopConnectorBinding(java.lang.String)
public java.util.List getConnectorBindings() throws MetaMatrixComponentException
getConnectorBindings
in interface DataService
MetaMatrixComponentException
DataService.getConnectorBindings()
public java.lang.Boolean getConnectorBindingState(java.lang.String deployedConnectorBindingName) throws MetaMatrixComponentException
getConnectorBindingState
in interface DataService
MetaMatrixComponentException
DataService.getConnectorBindingState(java.lang.String)
public void initializeService(java.util.Properties props) throws ApplicationInitializationException
initializeService
in class EmbeddedBaseDQPService
props
- Initialialization properties
ApplicationInitializationException
- If an error occurs during initializationpublic void startService(ApplicationEnvironment environment) throws ApplicationLifecycleException
startService
in class EmbeddedBaseDQPService
environment
- Environment
ApplicationLifecycleException
- If an error occurs while startingpublic void stopService() throws ApplicationLifecycleException
stopService
in class EmbeddedBaseDQPService
ApplicationLifecycleException
- If an error occurs while startingpublic ConnectorBinding getConnectorBinding(java.lang.String deployedConnectorBindingName) throws MetaMatrixComponentException
getConnectorBinding
in interface DataService
MetaMatrixComponentException
protected boolean isMaskedProperty(java.lang.String propName, ComponentType type)
propName
- type
-
protected java.lang.String decryptProperty(java.lang.String value) throws CryptoException
value
-
CryptoException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |