org.teiid.dqp.internal.process
Class DataTierManagerImpl

java.lang.Object
  org.teiid.dqp.internal.process.DataTierManagerImpl

All Implemented Interfaces:

ProcessorDataManager

public class DataTierManagerImpl
extends java.lang.Object
implements ProcessorDataManager

Full ProcessorDataManager implementation that controls access to ConnectorManagers and handles system queries.

Constructor Summary

DataTierManagerImpl(DQPCore requestMgr, BufferService bufferService, boolean detectChangeEvents)

Method Summary

boolean	detectChangeEvents()
static java.util.Collection<AbstractMetadataRecord>	getAllPropertiedObjects(CompositeMetadataStore metadata, java.util.Collection<Schema> schemas)
static AbstractMetadataRecord	getByUuid(CompositeMetadataStore metadata, java.lang.String uuid)
EventDistributor	getEventDistributor()
static int	getLevel(java.lang.String level)
MetadataRepository	getMetadataRepository()
java.lang.Object	lookupCodeValue(CommandContext context, java.lang.String codeTableName, java.lang.String returnElementName, java.lang.String keyElementName, java.lang.Object keyValue) Lookup a value from a cached code table.
TupleSource	registerRequest(CommandContext context, Command command, java.lang.String modelName, java.lang.String connectorBindingId, int nodeID, int limit)
void	setEventDistributor(EventDistributor eventDistributor)
void	setMetadataRepository(MetadataRepository metadataRepository)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataTierManagerImpl

public DataTierManagerImpl(DQPCore requestMgr,
                           BufferService bufferService,
                           boolean detectChangeEvents)

Method Detail

getLevel

public static int getLevel(java.lang.String level)
                    throws TeiidProcessingException

Throws:

TeiidProcessingException

detectChangeEvents

public boolean detectChangeEvents()

setEventDistributor

public void setEventDistributor(EventDistributor eventDistributor)

getEventDistributor

public EventDistributor getEventDistributor()

Specified by:

getEventDistributor in interface ProcessorDataManager

getMetadataRepository

public MetadataRepository getMetadataRepository()

Specified by:

getMetadataRepository in interface ProcessorDataManager

setMetadataRepository

public void setMetadataRepository(MetadataRepository metadataRepository)

registerRequest

public TupleSource registerRequest(CommandContext context,
                                   Command command,
                                   java.lang.String modelName,
                                   java.lang.String connectorBindingId,
                                   int nodeID,
                                   int limit)
                            throws TeiidComponentException,
                                   TeiidProcessingException

Specified by:

registerRequest in interface ProcessorDataManager

Throws:

TeiidComponentException

TeiidProcessingException

getByUuid

public static AbstractMetadataRecord getByUuid(CompositeMetadataStore metadata,
                                               java.lang.String uuid)

getAllPropertiedObjects

public static java.util.Collection<AbstractMetadataRecord> getAllPropertiedObjects(CompositeMetadataStore metadata,
                                                                                   java.util.Collection<Schema> schemas)

lookupCodeValue

public java.lang.Object lookupCodeValue(CommandContext context,
                                        java.lang.String codeTableName,
                                        java.lang.String returnElementName,
                                        java.lang.String keyElementName,
                                        java.lang.Object keyValue)
                                 throws BlockedException,
                                        TeiidComponentException,
                                        TeiidProcessingException

Description copied from interface: ProcessorDataManager

Lookup a value from a cached code table. If the code table is not loaded, it will be loaded on the first query. Code tables should be cached based on a combination of the codeTableName, returnElementName, and keyElementName. If the table is not loaded, a request will be made and the method should throw a BlockedException.

Specified by:

lookupCodeValue in interface ProcessorDataManager

Throws:

BlockedException

TeiidComponentException

TeiidProcessingException