public class ExecutionContextImpl extends Object implements ExecutionContext
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) |
public ExecutionContextImpl(String vdbName, Object vdbVersion, Serializable executionPayload, String originalConnectionID, String connectorName, long requestId, String partId, String execCount)
public ExecutionContextImpl(CommandContext commandContext, String connectorName, String partId, String execCount, ConnectorWorkItem workItem)
public CommandContext getCommandContext()
getCommandContext
in interface ExecutionContext
public String getConnectorIdentifier()
getConnectorIdentifier
in interface ExecutionContext
public String getRequestId()
getRequestId
in interface ExecutionContext
public String getPartIdentifier()
getPartIdentifier
in interface ExecutionContext
public String getExecutionCountIdentifier()
getExecutionCountIdentifier
in interface ExecutionContext
public String getVdbName()
getVdbName
in interface ExecutionContext
public String getVdbVersion()
getVdbVersion
in interface ExecutionContext
public Subject getSubject()
getSubject
in interface ExecutionContext
public Serializable getCommandPayload()
getCommandPayload
in interface ExecutionContext
public String getConnectionId()
getConnectionId
in interface ExecutionContext
public void keepExecutionAlive(boolean alive)
keepExecutionAlive
in interface ExecutionContext
public boolean isTransactional()
isTransactional
in interface ExecutionContext
public int getBatchSize()
getBatchSize
in interface ExecutionContext
public void setBatchSize(int batchSize)
public void addWarning(Exception ex)
addWarning
in interface ExecutionContext
public Session getSession()
getSession
in interface ExecutionContext
public void setSession(Session session)
public void dataAvailable()
dataAvailable
in interface ExecutionContext
public boolean isDataAvailable()
public String getGeneralHint()
getGeneralHint
in interface ExecutionContext
public String getSourceHint()
getSourceHint
in interface ExecutionContext
public Collection<String> getGeneralHints()
getGeneralHints
in interface ExecutionContext
public Collection<String> getSourceHints()
getSourceHints
in interface ExecutionContext
public void setGeneralHints(Collection<String> generalHint)
public void setHints(Collection<String> hint)
public String getConnectionID()
getConnectionID
in interface ExecutionContext
public Serializable getExecutionPayload()
getExecutionPayload
in interface ExecutionContext
public String getRequestID()
getRequestID
in interface ExecutionContext
public CacheDirective getCacheDirective()
getCacheDirective
in interface ExecutionContext
public void setCacheDirective(CacheDirective directive)
public void setRuntimeMetadata(RuntimeMetadataImpl queryMetadata)
public RuntimeMetadata getRuntimeMetadata()
getRuntimeMetadata
in interface ExecutionContext
public void logCommand(Object... command)
logCommand
in interface ExecutionContext
public CacheDirective.Scope getScope()
getScope
in interface ExecutionContext
public void setScope(CacheDirective.Scope scope)
setScope
in interface ExecutionContext
Copyright © 2019. All rights reserved.