org.teiid.dqp.internal.datamgr

Class ExecutionContextImpl

java.lang.Object

org.teiid.dqp.internal.datamgr.ExecutionContextImpl

All Implemented Interfaces:

ExecutionContext

public class ExecutionContextImpl
extends Object
implements ExecutionContext

Constructor Summary

Constructors

Constructor and Description
ExecutionContextImpl(CommandContext commandContext, String connectorName, String partId, String execCount, ConnectorWorkItem workItem)
ExecutionContextImpl(String vdbName, Object vdbVersion, Serializable executionPayload, String originalConnectionID, String connectorName, long requestId, String partId, String execCount)

Method Summary

Modifier and Type	Method and Description
void	addWarning(Exception ex) Add an exception as a warning to this Execution.
void	dataAvailable()
boolean	equals(Object obj)
int	getBatchSize()
CacheDirective	getCacheDirective()
CommandContext	getCommandContext()
Serializable	getCommandPayload()
String	getConnectionId()
String	getConnectionID()
String	getConnectorIdentifier()
String	getExecutionCountIdentifier()
Serializable	getExecutionPayload()
String	getGeneralHint()
Collection<String>	getGeneralHints()
List<Column>	getGeneratedKeyColumns()
String	getPartIdentifier()
String	getRequestId()
String	getRequestID()
RuntimeMetadata	getRuntimeMetadata()
CacheDirective.Scope	getScope()
Session	getSession()
String	getSourceHint()
Collection<String>	getSourceHints()
Subject	getSubject()
int	getTransactionIsolation()
String	getVdbName()
String	getVdbVersion()
List<Exception>	getWarnings()
int	hashCode()
boolean	isDataAvailable()
boolean	isTransactional()
void	keepExecutionAlive(boolean alive)
void	logCommand(Object... command)
GeneratedKeys	returnGeneratedKeys()
void	setBatchSize(int batchSize)
void	setCacheDirective(CacheDirective directive)
void	setGeneralHints(Collection<String> generalHint)
void	setGeneratedKeyColumns(Command translatedCommand)
void	setGeneratedKeyColumns(List<Column> generatedKeyColumns)
void	setHints(Collection<String> hint)
void	setRuntimeMetadata(RuntimeMetadataImpl queryMetadata)
void	setScope(CacheDirective.Scope scope)
void	setSession(Session session)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ExecutionContextImpl

public ExecutionContextImpl(String vdbName,
                            Object vdbVersion,
                            Serializable executionPayload,
                            String originalConnectionID,
                            String connectorName,
                            long requestId,
                            String partId,
                            String execCount)

ExecutionContextImpl

public ExecutionContextImpl(CommandContext commandContext,
                            String connectorName,
                            String partId,
                            String execCount,
                            ConnectorWorkItem workItem)

Method Detail

getCommandContext

public CommandContext getCommandContext()

Specified by:

getCommandContext in interface ExecutionContext

getConnectorIdentifier

public String getConnectorIdentifier()

Specified by:

getConnectorIdentifier in interface ExecutionContext

getRequestId

public String getRequestId()

Specified by:

getRequestId in interface ExecutionContext

getPartIdentifier

public String getPartIdentifier()

Specified by:

getPartIdentifier in interface ExecutionContext

getExecutionCountIdentifier

public String getExecutionCountIdentifier()

Specified by:

getExecutionCountIdentifier in interface ExecutionContext

getVdbName

public String getVdbName()

Specified by:

getVdbName in interface ExecutionContext

getVdbVersion

public String getVdbVersion()

Specified by:

getVdbVersion in interface ExecutionContext

getSubject

public Subject getSubject()

Specified by:

getSubject in interface ExecutionContext

getCommandPayload

public Serializable getCommandPayload()

Specified by:

getCommandPayload in interface ExecutionContext

getConnectionId

public String getConnectionId()

Specified by:

getConnectionId in interface ExecutionContext

keepExecutionAlive

public void keepExecutionAlive(boolean alive)

Specified by:

keepExecutionAlive in interface ExecutionContext

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

isTransactional

public boolean isTransactional()

Specified by:

isTransactional in interface ExecutionContext

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface ExecutionContext

setBatchSize

public void setBatchSize(int batchSize)

addWarning

public void addWarning(Exception ex)

Add an exception as a warning to this Execution.

Specified by:

addWarning in interface ExecutionContext

getWarnings

public List<Exception> getWarnings()

getSession

public Session getSession()

Specified by:

getSession in interface ExecutionContext

setSession

public void setSession(Session session)

dataAvailable

public void dataAvailable()

Specified by:

dataAvailable in interface ExecutionContext

isDataAvailable

public boolean isDataAvailable()

getGeneralHint

public String getGeneralHint()

Specified by:

getGeneralHint in interface ExecutionContext

getSourceHint

public String getSourceHint()

Specified by:

getSourceHint in interface ExecutionContext

getGeneralHints

public Collection<String> getGeneralHints()

Specified by:

getGeneralHints in interface ExecutionContext

getSourceHints

public Collection<String> getSourceHints()

Specified by:

getSourceHints in interface ExecutionContext

setGeneralHints

public void setGeneralHints(Collection<String> generalHint)

setHints

public void setHints(Collection<String> hint)

getConnectionID

public String getConnectionID()

Specified by:

getConnectionID in interface ExecutionContext

getExecutionPayload

public Serializable getExecutionPayload()

Specified by:

getExecutionPayload in interface ExecutionContext

getRequestID

public String getRequestID()

Specified by:

getRequestID in interface ExecutionContext

getCacheDirective

public CacheDirective getCacheDirective()

Specified by:

getCacheDirective in interface ExecutionContext

setCacheDirective

public void setCacheDirective(CacheDirective directive)

setRuntimeMetadata

public void setRuntimeMetadata(RuntimeMetadataImpl queryMetadata)

getRuntimeMetadata

public RuntimeMetadata getRuntimeMetadata()

Specified by:

getRuntimeMetadata in interface ExecutionContext

logCommand

public void logCommand(Object... command)

Specified by:

logCommand in interface ExecutionContext

getScope

public CacheDirective.Scope getScope()

Specified by:

getScope in interface ExecutionContext

setScope

public void setScope(CacheDirective.Scope scope)

Specified by:

setScope in interface ExecutionContext

getGeneratedKeyColumns

public List<Column> getGeneratedKeyColumns()

Specified by:

getGeneratedKeyColumns in interface ExecutionContext

setGeneratedKeyColumns

public void setGeneratedKeyColumns(List<Column> generatedKeyColumns)

returnGeneratedKeys

public GeneratedKeys returnGeneratedKeys()

Specified by:

returnGeneratedKeys in interface ExecutionContext

setGeneratedKeyColumns

public void setGeneratedKeyColumns(Command translatedCommand)

getTransactionIsolation

public int getTransactionIsolation()

Specified by:

getTransactionIsolation in interface ExecutionContext