org.teiid.dqp.message
Class AtomicRequestMessage

java.lang.Object
  org.teiid.dqp.message.AtomicRequestMessage

All Implemented Interfaces:

java.io.Serializable

public class AtomicRequestMessage
extends java.lang.Object
implements java.io.Serializable

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

See Also:

Serialized Form

Constructor Summary

AtomicRequestMessage()

AtomicRequestMessage(RequestMessage requestMessage, org.teiid.dqp.internal.process.DQPWorkContext parent, int nodeId)

Method Summary

AtomicRequestID	getAtomicRequestID()
Command	getCommand()
java.lang.String	getConnectorName()
java.io.Serializable	getExecutionPayload()
int	getFetchSize()
int	getMaxResultRows()
java.lang.String	getModelName()
long	getProcessingTimestamp() Get time that the request was assigned a unique ID by the server.
RequestID	getRequestID()
TransactionContext	getTransactionContext()
org.teiid.dqp.internal.process.DQPWorkContext	getWorkContext()
boolean	isExceptionOnMaxRows()
boolean	isTransactional()
void	setCommand(Command command)
void	setConnectorName(java.lang.String string)
void	setExceptionOnMaxRows(boolean exceptionOnMaxRows)
void	setExecutionPayload(java.io.Serializable executionPayload)
void	setFetchSize(int fetchSize)
void	setMaxResultRows(int maxRows)
void	setModelName(java.lang.String modelName)
void	setPartialResults(boolean partial)
void	setRequestID(RequestID requestID)
void	setTransactionContext(TransactionContext context)
void	setWorkContext(org.teiid.dqp.internal.process.DQPWorkContext workContext)
boolean	supportsPartialResults()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AtomicRequestMessage

public AtomicRequestMessage()

AtomicRequestMessage

public AtomicRequestMessage(RequestMessage requestMessage,
                            org.teiid.dqp.internal.process.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 java.lang.String getConnectorName()

setConnectorName

public void setConnectorName(java.lang.String string)

getModelName

public java.lang.String getModelName()

setModelName

public void setModelName(java.lang.String modelName)

getTransactionContext

public TransactionContext getTransactionContext()

setTransactionContext

public void setTransactionContext(TransactionContext context)

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

setExecutionPayload

public void setExecutionPayload(java.io.Serializable executionPayload)

getExecutionPayload

public java.io.Serializable getExecutionPayload()

setRequestID

public void setRequestID(RequestID requestID)

getRequestID

public RequestID getRequestID()

setWorkContext

public void setWorkContext(org.teiid.dqp.internal.process.DQPWorkContext workContext)

getWorkContext

public org.teiid.dqp.internal.process.DQPWorkContext getWorkContext()