org.teiid.dqp.internal.datamgr

Class ConnectorManager

java.lang.Object

org.teiid.dqp.internal.datamgr.ConnectorManager

public class ConnectorManager
extends Object

The ConnectorManager manages an ExecutionFactory and its associated workers' state.

Constructor Summary

Constructors

Constructor and Description
ConnectorManager(String translatorName, String connectionName)
ConnectorManager(String translatorName, String connectionName, ExecutionFactory<Object,Object> ef)

Method Summary

Modifier and Type	Method and Description
SourceCapabilities	getCapabilities()
Object	getConnectionFactory() Get the ConnectionFactory object required by this manager
String	getConnectionName()
ExecutionFactory<Object,Object>	getExecutionFactory() Get the Translator object managed by this manager.
List<String>	getId()
List<FunctionMethod>	getPushDownFunctions()
String	getStausMessage()
String	getTranslatorName()
ConnectorWork	registerRequest(AtomicRequestMessage message)
void	start() initialize this ConnectorManager.
void	stop() Stop this connector.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectorManager

public ConnectorManager(String translatorName,
                        String connectionName)

ConnectorManager

public ConnectorManager(String translatorName,
                        String connectionName,
                        ExecutionFactory<Object,Object> ef)

Method Detail

getStausMessage

public String getStausMessage()

getPushDownFunctions

public List<FunctionMethod> getPushDownFunctions()

getCapabilities

public SourceCapabilities getCapabilities()
                                   throws TranslatorException,
                                          TeiidComponentException

Throws:

TranslatorException

TeiidComponentException

registerRequest

public ConnectorWork registerRequest(AtomicRequestMessage message)
                              throws TeiidComponentException

Throws:

TeiidComponentException

start

public void start()

initialize this ConnectorManager.

Throws:

TranslatorException

stop

public void stop()

Stop this connector.

getExecutionFactory

public ExecutionFactory<Object,Object> getExecutionFactory()

Get the Translator object managed by this manager.

Returns:

the ExecutionFactory.

getConnectionFactory

public Object getConnectionFactory()
                            throws TranslatorException

Get the ConnectionFactory object required by this manager

Returns:

Throws:

TranslatorException

getTranslatorName

public String getTranslatorName()

getConnectionName

public String getConnectionName()

getId

public List<String> getId()