|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.metamatrix.server.dqp.service.PlatformDataService
public class PlatformDataService
Platform DataService.
A DQP service used to lookup ConnectorService
s.
Constructor Summary | |
---|---|
PlatformDataService()
DQPDataService Default ctor. |
Method Summary | |
---|---|
void |
cancelRequest(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
void |
clearConnectorBindingCache(java.lang.String connectorBindingName)
Clear any caches for the connector binding. |
void |
closeRequest(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
void |
executeRequest(AtomicRequestMessage request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId,
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 connectorId)
Find the capabilities of this source. |
java.util.Collection |
getConnectionPoolStatistics(java.lang.String connectorBindingName)
Get connection pool statistics for connector binding |
ConnectorBinding |
getConnectorBinding(java.lang.String connectorBindingName)
Get the connector binding specifed the name |
java.util.List |
getConnectorBindings()
Get the list of connector bindings deployed in the system. |
java.lang.Boolean |
getConnectorBindingState(java.lang.String connectorBindingName)
Get the State of the connector binding name |
java.util.Collection |
getConnectorBindingStatistics(java.lang.String connectorBindingName)
Get connector bindings queue statistics |
void |
initialize(java.util.Properties props)
Initialize the service with the specified properties. |
void |
requestBatch(AtomicRequestID request,
com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId)
|
com.metamatrix.dqp.internal.datamgr.ConnectorID |
selectConnector(java.lang.String connectorBindingID)
Select a connector to use for the given connector binding. |
void |
start(ApplicationEnvironment environment)
Start the service with the specified environment. |
void |
startConnectorBinding(java.lang.String connectorBindingName)
Start the Connector Binding by the name given, if it is already added and not srarted. |
void |
stop()
Stop the service. |
void |
stopConnectorBinding(java.lang.String connectorBindingName)
Stop the Connector Binding by the given name |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PlatformDataService()
Method Detail |
---|
public com.metamatrix.dqp.internal.datamgr.ConnectorID selectConnector(java.lang.String connectorBindingID)
selectConnector
in interface DataService
connectorBindingID
- Connector binding identifier
public void executeRequest(AtomicRequestMessage request, com.metamatrix.dqp.internal.datamgr.ConnectorID connectorId, ResultsReceiver<AtomicResultsMessage> resultListener) throws MetaMatrixComponentException
Connector
.
executeRequest
in interface DataService
request
- The request for data.
MetaMatrixComponentException
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 connectorId) throws MetaMatrixComponentException
DataService
getCapabilities
in interface DataService
request
- Original request message, used to extract security informationconnectorId
- Connector to retrieve capabilities from
MetaMatrixComponentException
public void initialize(java.util.Properties props) throws ApplicationInitializationException
initialize
in interface ApplicationService
props
- Initialialization properties
ApplicationInitializationException
- If an error occurs during initializationpublic void start(ApplicationEnvironment environment) throws ApplicationLifecycleException
start
in interface ApplicationService
environment
- Environment
ApplicationLifecycleException
- If an error occurs while startingpublic void stop() throws ApplicationLifecycleException
stop
in interface ApplicationService
ApplicationLifecycleException
- If an error occurs while startingpublic void startConnectorBinding(java.lang.String connectorBindingName) throws ApplicationLifecycleException, ComponentNotFoundException
DataService
startConnectorBinding
in interface DataService
ApplicationLifecycleException
ComponentNotFoundException
DataService.startConnectorBinding(java.lang.String)
public void stopConnectorBinding(java.lang.String connectorBindingName) throws ApplicationLifecycleException, ComponentNotFoundException
DataService
stopConnectorBinding
in interface DataService
ApplicationLifecycleException
ComponentNotFoundException
DataService.stopConnectorBinding(java.lang.String)
public java.util.List getConnectorBindings() throws ComponentNotFoundException
DataService
getConnectorBindings
in interface DataService
ConnectorBinding
ComponentNotFoundException
DataService.getConnectorBindings()
public java.lang.Boolean getConnectorBindingState(java.lang.String connectorBindingName) throws MetaMatrixComponentException
DataService
getConnectorBindingState
in interface DataService
com.metamatrix.connector.monitor.AliveStatus
MetaMatrixComponentException
DataService.getConnectorBindingState(java.lang.String)
public ConnectorBinding getConnectorBinding(java.lang.String connectorBindingName) throws MetaMatrixComponentException
DataService
getConnectorBinding
in interface DataService
ComponentNotFoundException
MetaMatrixComponentException
DataService.getConnectorBinding(java.lang.String)
public java.util.Collection getConnectorBindingStatistics(java.lang.String connectorBindingName) throws MetaMatrixComponentException
DataService
getConnectorBindingStatistics
in interface DataService
connectorBindingName
- - Name of the connector binding
WorkerPoolStats
MetaMatrixComponentException
DataService.getConnectorBindingStatistics(java.lang.String)
public java.util.Collection getConnectionPoolStatistics(java.lang.String connectorBindingName) throws MetaMatrixComponentException
DataService
getConnectionPoolStatistics
in interface DataService
connectorBindingName
- - Name of the connector binding
ConnectionPoolStats
MetaMatrixComponentException
DataService.getConnectionPoolStatistics(java.lang.String)
public void clearConnectorBindingCache(java.lang.String connectorBindingName) throws MetaMatrixComponentException
DataService
clearConnectorBindingCache
in interface DataService
MetaMatrixComponentException
DataService.clearConnectorBindingCache(java.lang.String)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |