org.teiid.dqp.internal.datamgr
Class ExecutionContextImpl

java.lang.Object
  org.teiid.dqp.internal.datamgr.ExecutionContextImpl

All Implemented Interfaces:

ExecutionContext

public class ExecutionContextImpl
extends java.lang.Object
implements ExecutionContext

Constructor Summary

ExecutionContextImpl(java.lang.String vdbName, int vdbVersion, java.io.Serializable executionPayload, java.lang.String originalConnectionID, java.lang.String connectorName, java.lang.String requestId, java.lang.String partId, java.lang.String execCount)

Method Summary

void	addWarning(java.lang.Exception ex) Add an exception as a warning to this Execution.
boolean	equals(java.lang.Object obj)
int	getBatchSize()
java.lang.String	getConnectionIdentifier()
java.lang.String	getConnectorIdentifier()
java.lang.String	getExecutionCountIdentifier()
java.io.Serializable	getExecutionPayload()
java.lang.String	getPartIdentifier()
java.lang.String	getRequestIdentifier()
Session	getSession()
javax.security.auth.Subject	getSubject()
java.lang.String	getVirtualDatabaseName()
int	getVirtualDatabaseVersion()
java.util.List<java.lang.Exception>	getWarnings()
int	hashCode()
boolean	isTransactional()
void	keepExecutionAlive(boolean alive)
void	setBatchSize(int batchSize)
void	setSession(Session session)
void	setUser(javax.security.auth.Subject user)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionContextImpl

public ExecutionContextImpl(java.lang.String vdbName,
                            int vdbVersion,
                            java.io.Serializable executionPayload,
                            java.lang.String originalConnectionID,
                            java.lang.String connectorName,
                            java.lang.String requestId,
                            java.lang.String partId,
                            java.lang.String execCount)

Method Detail

getConnectorIdentifier

public java.lang.String getConnectorIdentifier()

Specified by:

getConnectorIdentifier in interface ExecutionContext

getRequestIdentifier

public java.lang.String getRequestIdentifier()

Specified by:

getRequestIdentifier in interface ExecutionContext

getPartIdentifier

public java.lang.String getPartIdentifier()

Specified by:

getPartIdentifier in interface ExecutionContext

getExecutionCountIdentifier

public java.lang.String getExecutionCountIdentifier()

Specified by:

getExecutionCountIdentifier in interface ExecutionContext

getVirtualDatabaseName

public java.lang.String getVirtualDatabaseName()

Specified by:

getVirtualDatabaseName in interface ExecutionContext

getVirtualDatabaseVersion

public int getVirtualDatabaseVersion()

Specified by:

getVirtualDatabaseVersion in interface ExecutionContext

getSubject

public javax.security.auth.Subject getSubject()

Specified by:

getSubject in interface ExecutionContext

setUser

public void setUser(javax.security.auth.Subject user)

getExecutionPayload

public java.io.Serializable getExecutionPayload()

Specified by:

getExecutionPayload in interface ExecutionContext

getConnectionIdentifier

public java.lang.String getConnectionIdentifier()

Specified by:

getConnectionIdentifier in interface ExecutionContext

keepExecutionAlive

public void keepExecutionAlive(boolean alive)

Specified by:

keepExecutionAlive in interface ExecutionContext

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.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(java.lang.Exception ex)

Add an exception as a warning to this Execution.

Specified by:

addWarning in interface ExecutionContext

getWarnings

public java.util.List<java.lang.Exception> getWarnings()

getSession

public Session getSession()

Specified by:

getSession in interface ExecutionContext

setSession

public void setSession(Session session)