Package org.teiid.query.tempdata

Class TempTableDataManager

java.lang.Object

org.teiid.query.tempdata.TempTableDataManager

All Implemented Interfaces:

ProcessorDataManager

public class TempTableDataManager
extends 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)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	TempTableDataManager.ProxyTupleSource
static interface	TempTableDataManager.RequestExecutor

Field Summary

Fields

Modifier and Type	Field	Description
static String	CODE_PREFIX

Constructor Summary

Constructors

Constructor	Description
TempTableDataManager(ProcessorDataManager processorDataManager, BufferManager bufferManager, SessionAwareCache<CachedResults> cache)

Method Summary

Modifier and Type	Method	Description
static SessionMetadata	createTemporarySession(String userName, String app, VDBMetaData vdb)	Create an unauthenticated session
EventDistributor	getEventDistributor()
Object	lookupCodeValue(CommandContext context, String codeTableName, String returnElementName, String keyElementName, Object keyValue)	Lookup a value from a cached code table.
TupleSource	registerRequest(CommandContext context, Command command, String modelName, RegisterRequestParameter parameterObject)
void	setEventDistributor(EventDistributor eventDistributor)
void	setExecutor(TempTableDataManager.RequestExecutor executor)
static boolean	shouldInvalidate(VDBMetaData vdb)

Methods inherited from class java.lang.Object

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

Field Detail

CODE_PREFIX

public static final String CODE_PREFIX

See Also:

Constant Field Values

Constructor Detail

TempTableDataManager

public TempTableDataManager(ProcessorDataManager processorDataManager,
                            BufferManager bufferManager,
                            SessionAwareCache<CachedResults> cache)

Method Detail

setExecutor

public void setExecutor(TempTableDataManager.RequestExecutor executor)

setEventDistributor

public void setEventDistributor(EventDistributor eventDistributor)

registerRequest

public TupleSource registerRequest(CommandContext context,
                                   Command command,
                                   String modelName,
                                   RegisterRequestParameter parameterObject)
                            throws TeiidComponentException,
                                   TeiidProcessingException

Specified by:

registerRequest in interface ProcessorDataManager

Throws:

TeiidComponentException

TeiidProcessingException

lookupCodeValue

public Object lookupCodeValue(CommandContext context,
                              String codeTableName,
                              String returnElementName,
                              String keyElementName,
                              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

createTemporarySession

public static SessionMetadata createTemporarySession(String userName,
                                                     String app,
                                                     VDBMetaData vdb)

Create an unauthenticated session

Parameters:

userName -

app -

vdb -

Returns:

shouldInvalidate

public static boolean shouldInvalidate(VDBMetaData vdb)