org.teiid.dqp.message

Class AtomicRequestMessage

java.lang.Object

org.teiid.dqp.message.AtomicRequestMessage

public class AtomicRequestMessage
extends Object

This class defines a request message for the Connector layer. This is uniquely identified by AtomicRequestID.

Constructor Summary

Constructors

Constructor and Description
AtomicRequestMessage(RequestMessage requestMessage, DQPWorkContext parent, int nodeId)

Method Summary

Modifier and Type	Method and Description
AtomicRequestID	getAtomicRequestID()
BufferManager	getBufferManager()
Command	getCommand()
CommandContext	getCommandContext()
String	getConnectorName()
int	getFetchSize()
int	getMaxResultRows()
String	getModelName()
long	getProcessingTimestamp() Get time that the request was assigned a unique ID by the server.
RequestID	getRequestID()
TransactionContext	getTransactionContext()
DQPWorkContext	getWorkContext()
boolean	isCopyStreamingLobs()
boolean	isExceptionOnMaxRows()
boolean	isSerial()
boolean	isTransactional()
void	setBufferManager(BufferManager bufferManager)
void	setCommand(Command command)
void	setCommandContext(CommandContext commandContext)
void	setConnectorName(String string)
void	setCopyStreamingLobs(boolean copyStreamingLobs)
void	setExceptionOnMaxRows(boolean exceptionOnMaxRows)
void	setFetchSize(int fetchSize)
void	setMaxResultRows(int maxRows)
void	setModelName(String modelName)
void	setPartialResults(boolean partial)
void	setRequestID(RequestID requestID)
void	setSerial(boolean serial)
void	setTransactionContext(TransactionContext context)
void	setWorkContext(DQPWorkContext workContext)
boolean	supportsPartialResults()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AtomicRequestMessage

public AtomicRequestMessage(RequestMessage requestMessage,
                            DQPWorkContext parent,
                            int nodeId)

Method Detail

getMaxResultRows

public int getMaxResultRows()

setMaxResultRows

public void setMaxResultRows(int maxRows)

isExceptionOnMaxRows

public boolean isExceptionOnMaxRows()

setExceptionOnMaxRows

public void setExceptionOnMaxRows(boolean exceptionOnMaxRows)

getAtomicRequestID

public AtomicRequestID getAtomicRequestID()

getConnectorName

public String getConnectorName()

setConnectorName

public void setConnectorName(String string)

getModelName

public String getModelName()

setModelName

public void setModelName(String modelName)

getTransactionContext

public TransactionContext getTransactionContext()

setTransactionContext

public void setTransactionContext(TransactionContext context)

isSerial

public boolean isSerial()

setSerial

public void setSerial(boolean serial)

isTransactional

public boolean isTransactional()

getCommand

public Command getCommand()

setCommand

public void setCommand(Command command)

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int fetchSize)

getProcessingTimestamp

public long getProcessingTimestamp()

Get time that the request was assigned a unique ID by the server.

Returns:

timestamp in millis

supportsPartialResults

public boolean supportsPartialResults()

setPartialResults

public void setPartialResults(boolean partial)

toString

public String toString()

Overrides:

toString in class Object

setRequestID

public void setRequestID(RequestID requestID)

getRequestID

public RequestID getRequestID()

setWorkContext

public void setWorkContext(DQPWorkContext workContext)

getWorkContext

public DQPWorkContext getWorkContext()

getCommandContext

public CommandContext getCommandContext()

setCommandContext

public void setCommandContext(CommandContext commandContext)

getBufferManager

public BufferManager getBufferManager()

setBufferManager

public void setBufferManager(BufferManager bufferManager)

isCopyStreamingLobs

public boolean isCopyStreamingLobs()

setCopyStreamingLobs

public void setCopyStreamingLobs(boolean copyStreamingLobs)