org.teiid.query.tempdata
Class TempTableDataManager

java.lang.Object
  org.teiid.query.tempdata.TempTableDataManager

All Implemented Interfaces:

ProcessorDataManager

public class TempTableDataManager
extends java.lang.Object
implements ProcessorDataManager

This proxy ProcessorDataManager is used to handle temporary tables. This isn't handled as a connector because of the temporary metadata and the create/drop handling (which doesn't have push down support)

Constructor Summary

TempTableDataManager(ProcessorDataManager processorDataManager, BufferManager bufferManager, java.util.concurrent.Executor executor, SessionAwareCache<CachedResults> cache, SessionAwareCache<CachedResults> distibutedCache, CacheFactory cacheFactory)

Method Summary

EventDistributor	getEventDistributor()
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.
void	refreshMatView(java.lang.String vdbName, int vdbVersion, java.lang.String viewName, QueryMetadataInterface metadata, TempTableStore globalStore)
TupleSource	registerRequest(CommandContext context, Command command, java.lang.String modelName, java.lang.String connectorBindingId, int nodeID, int limit)
void	setEventDistributor(EventDistributor eventDistributor)
java.util.List<?>	updateMatViewRow(TempTableStore globalStore, java.lang.String matTableName, java.util.List<?> tuple, boolean delete)

Methods inherited from class java.lang.Object

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

Constructor Detail

TempTableDataManager

public TempTableDataManager(ProcessorDataManager processorDataManager,
                            BufferManager bufferManager,
                            java.util.concurrent.Executor executor,
                            SessionAwareCache<CachedResults> cache,
                            SessionAwareCache<CachedResults> distibutedCache,
                            CacheFactory cacheFactory)

Method Detail

setEventDistributor

public void setEventDistributor(EventDistributor eventDistributor)

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

updateMatViewRow

public java.util.List<?> updateMatViewRow(TempTableStore globalStore,
                                          java.lang.String matTableName,
                                          java.util.List<?> tuple,
                                          boolean delete)
                                   throws QueryProcessingException,
                                          TeiidComponentException

Throws:

QueryProcessingException

TeiidComponentException

refreshMatView

public void refreshMatView(java.lang.String vdbName,
                           int vdbVersion,
                           java.lang.String viewName,
                           QueryMetadataInterface metadata,
                           TempTableStore globalStore)
                    throws QueryProcessingException,
                           TeiidComponentException,
                           TeiidProcessingException

Throws:

QueryProcessingException

TeiidComponentException

TeiidProcessingException

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

getEventDistributor

public EventDistributor getEventDistributor()

Specified by:

getEventDistributor in interface ProcessorDataManager

getMetadataRepository

public MetadataRepository getMetadataRepository()

Specified by:

getMetadataRepository in interface ProcessorDataManager