Package 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 Description ExecutionContextImpl(String vdbName, Object vdbVersion, Serializable executionPayload, String originalConnectionID, String connectorName, long requestId, String partId, String execCount)
ExecutionContextImpl(CommandContext commandContext, String connectorName, String partId, String execCount, ConnectorWorkItem workItem)
-
Method Summary
-
-
-
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 interfaceExecutionContext
-
getConnectorIdentifier
public String getConnectorIdentifier()
- Specified by:
getConnectorIdentifier
in interfaceExecutionContext
-
getRequestId
public String getRequestId()
- Specified by:
getRequestId
in interfaceExecutionContext
-
getPartIdentifier
public String getPartIdentifier()
- Specified by:
getPartIdentifier
in interfaceExecutionContext
-
getExecutionCountIdentifier
public String getExecutionCountIdentifier()
- Specified by:
getExecutionCountIdentifier
in interfaceExecutionContext
-
getVdbName
public String getVdbName()
- Specified by:
getVdbName
in interfaceExecutionContext
-
getVdbVersion
public String getVdbVersion()
- Specified by:
getVdbVersion
in interfaceExecutionContext
-
getSubject
public Subject getSubject()
- Specified by:
getSubject
in interfaceExecutionContext
-
getCommandPayload
public Serializable getCommandPayload()
- Specified by:
getCommandPayload
in interfaceExecutionContext
-
getConnectionId
public String getConnectionId()
- Specified by:
getConnectionId
in interfaceExecutionContext
-
keepExecutionAlive
public void keepExecutionAlive(boolean alive)
- Specified by:
keepExecutionAlive
in interfaceExecutionContext
-
isTransactional
public boolean isTransactional()
- Specified by:
isTransactional
in interfaceExecutionContext
-
getBatchSize
public int getBatchSize()
- Specified by:
getBatchSize
in interfaceExecutionContext
-
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 interfaceExecutionContext
-
getSession
public Session getSession()
- Specified by:
getSession
in interfaceExecutionContext
-
setSession
public void setSession(Session session)
-
dataAvailable
public void dataAvailable()
- Specified by:
dataAvailable
in interfaceExecutionContext
-
isDataAvailable
public boolean isDataAvailable()
-
getGeneralHint
public String getGeneralHint()
- Specified by:
getGeneralHint
in interfaceExecutionContext
-
getSourceHint
public String getSourceHint()
- Specified by:
getSourceHint
in interfaceExecutionContext
-
getGeneralHints
public Collection<String> getGeneralHints()
- Specified by:
getGeneralHints
in interfaceExecutionContext
-
getSourceHints
public Collection<String> getSourceHints()
- Specified by:
getSourceHints
in interfaceExecutionContext
-
setGeneralHints
public void setGeneralHints(Collection<String> generalHint)
-
setHints
public void setHints(Collection<String> hint)
-
getConnectionID
public String getConnectionID()
- Specified by:
getConnectionID
in interfaceExecutionContext
-
getExecutionPayload
public Serializable getExecutionPayload()
- Specified by:
getExecutionPayload
in interfaceExecutionContext
-
getRequestID
public String getRequestID()
- Specified by:
getRequestID
in interfaceExecutionContext
-
getCacheDirective
public CacheDirective getCacheDirective()
- Specified by:
getCacheDirective
in interfaceExecutionContext
-
setCacheDirective
public void setCacheDirective(CacheDirective directive)
-
setRuntimeMetadata
public void setRuntimeMetadata(RuntimeMetadataImpl queryMetadata)
-
getRuntimeMetadata
public RuntimeMetadata getRuntimeMetadata()
- Specified by:
getRuntimeMetadata
in interfaceExecutionContext
-
logCommand
public void logCommand(Object... command)
- Specified by:
logCommand
in interfaceExecutionContext
-
getScope
public CacheDirective.Scope getScope()
- Specified by:
getScope
in interfaceExecutionContext
-
setScope
public void setScope(CacheDirective.Scope scope)
- Specified by:
setScope
in interfaceExecutionContext
-
getGeneratedKeyColumns
public List<Column> getGeneratedKeyColumns()
- Specified by:
getGeneratedKeyColumns
in interfaceExecutionContext
-
returnGeneratedKeys
public GeneratedKeys returnGeneratedKeys()
- Specified by:
returnGeneratedKeys
in interfaceExecutionContext
-
setGeneratedKeyColumns
public void setGeneratedKeyColumns(Command translatedCommand)
-
getTransactionIsolation
public int getTransactionIsolation()
- Specified by:
getTransactionIsolation
in interfaceExecutionContext
-
-