org.gridgain.grid.kernal

Class GridJobExecuteRequest

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

org.gridgain.grid.kernal.GridJobExecuteRequest

All Implemented Interfaces:

Serializable, Cloneable, GridTaskMessage

public class GridJobExecuteRequest
extends GridTcpCommunicationMessageAdapter
implements GridTaskMessage

Job execution request.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

BIT_SET_NOT_READ, BOOLEAN_ARR_NOT_READ, BYTE_ARR_LIST_NOT_READ, BYTE_ARR_NOT_READ, CACHE_VER_NOT_READ, CHAR_ARR_NOT_READ, CLOCK_DELTA_VER_NOT_READ, commState, DHT_PART_EXCHANGE_ID_NOT_READ, DOUBLE_ARR_NOT_READ, DR_INT_REQ_ENTRY_NOT_READ, ENUM_NOT_READ, FLOAT_ARR_NOT_READ, GRID_UUID_NOT_READ, INT_ARR_NOT_READ, LONG_ARR_NOT_READ, LONG_LIST_NOT_READ, MSG_NOT_READ, NULL, SHORT_ARR_NOT_READ, STR_NOT_READ, UUID_NOT_READ, VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridJobExecuteRequest() No-op constructor to support Externalizable interface.
GridJobExecuteRequest(GridUuid sesId, GridUuid jobId, String taskName, String userVer, String taskClsName, byte[] jobBytes, GridComputeJob job, long startTaskTime, long timeout, Collection<UUID> top, byte[] siblingsBytes, Collection<GridComputeJobSibling> siblings, byte[] sesAttrsBytes, Map<Object,Object> sesAttrs, byte[] jobAttrsBytes, Map<? extends Serializable,? extends Serializable> jobAttrs, String cpSpi, GridUuid clsLdrId, GridDeploymentMode depMode, boolean dynamicSiblings, Map<UUID,GridUuid> ldrParticipants, boolean forceLocDep, boolean sesFullSup, boolean internal)

Method Summary

Methods

Modifier and Type	Method and Description
GridTcpCommunicationMessageAdapter	clone()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
byte	directType()
String	getCheckpointSpi()
GridUuid	getClassLoaderId()
long	getCreateTime() Gets this instance creation time.
GridDeploymentMode	getDeploymentMode()
GridComputeJob	getJob()
Map<? extends Serializable,? extends Serializable>	getJobAttributes()
byte[]	getJobAttributesBytes()
byte[]	getJobBytes()
GridUuid	getJobId()
Map<UUID,GridUuid>	getLoaderParticipants()
Map<Object,Object>	getSessionAttributes()
byte[]	getSessionAttributesBytes()
GridUuid	getSessionId()
Collection<GridComputeJobSibling>	getSiblings()
byte[]	getSiblingsBytes()
long	getStartTaskTime()
String	getTaskClassName()
String	getTaskName()
long	getTimeout()
String	getUserVersion()
boolean	isDynamicSiblings() Returns true if siblings list is dynamic, i.e.
boolean	isForceLocalDeployment()
boolean	isInternal()
boolean	isSessionFullSupport()
boolean	readFrom(ByteBuffer buf)
Collection<UUID>	topology()
String	toString()
boolean	writeTo(ByteBuffer buf)

Methods inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

arrayIterator, messageReader, messageWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

GridJobExecuteRequest

public GridJobExecuteRequest()

No-op constructor to support Externalizable interface.

GridJobExecuteRequest

public GridJobExecuteRequest(GridUuid sesId,
                     GridUuid jobId,
                     String taskName,
                     String userVer,
                     String taskClsName,
                     byte[] jobBytes,
                     GridComputeJob job,
                     long startTaskTime,
                     long timeout,
                     @Nullable
                     Collection<UUID> top,
                     byte[] siblingsBytes,
                     Collection<GridComputeJobSibling> siblings,
                     byte[] sesAttrsBytes,
                     Map<Object,Object> sesAttrs,
                     byte[] jobAttrsBytes,
                     Map<? extends Serializable,? extends Serializable> jobAttrs,
                     String cpSpi,
                     GridUuid clsLdrId,
                     GridDeploymentMode depMode,
                     boolean dynamicSiblings,
                     Map<UUID,GridUuid> ldrParticipants,
                     boolean forceLocDep,
                     boolean sesFullSup,
                     boolean internal)

Parameters:

sesId - Task session ID.

jobId - Job ID.

taskName - Task name.

userVer - Code version.

taskClsName - Fully qualified task name.

jobBytes - Job serialized body.

job - Job.

startTaskTime - Task execution start time.

timeout - Task execution timeout.

top - Topology.

siblingsBytes - Serialized collection of split siblings.

siblings - Collection of split siblings.

sesAttrsBytes - Map of session attributes.

sesAttrs - Session attributes.

jobAttrsBytes - Job context attributes.

jobAttrs - Job attributes.

cpSpi - Collision SPI.

clsLdrId - Task local class loader id.

depMode - Task deployment mode.

dynamicSiblings - True if siblings are dynamic.

ldrParticipants - Other node class loader IDs that can also load classes.

forceLocDep - True If remote node should ignore deployment settings.

sesFullSup - True if session attributes are disabled.

internal - True if internal job.

Method Detail

getSessionId

public GridUuid getSessionId()

Specified by:

getSessionId in interface GridTaskMessage

Returns:

Session ID.

getJobId

public GridUuid getJobId()

Returns:

Job session ID.

getTaskClassName

public String getTaskClassName()

Returns:

Task version.

getTaskName

public String getTaskName()

Returns:

Task name.

getUserVersion

public String getUserVersion()

Returns:

Task version.

getJobBytes

public byte[] getJobBytes()

Returns:

Serialized job bytes.

getJob

public GridComputeJob getJob()

Returns:

Grid job.

getStartTaskTime

public long getStartTaskTime()

Returns:

Task start time.

getTimeout

public long getTimeout()

Returns:

Timeout.

getCreateTime

public long getCreateTime()

Gets this instance creation time.

Returns:

This instance creation time.

getSiblingsBytes

public byte[] getSiblingsBytes()

Returns:

Serialized collection of split siblings.

getSiblings

public Collection<GridComputeJobSibling> getSiblings()

Returns:

Job siblings.

getSessionAttributesBytes

public byte[] getSessionAttributesBytes()

Returns:

Session attributes.

getSessionAttributes

public Map<Object,Object> getSessionAttributes()

Returns:

Session attributes.

getJobAttributesBytes

public byte[] getJobAttributesBytes()

Returns:

Job attributes.

getJobAttributes

public Map<? extends Serializable,? extends Serializable> getJobAttributes()

Returns:

Job attributes.

getCheckpointSpi

public String getCheckpointSpi()

Returns:

Checkpoint SPI name.

getClassLoaderId

public GridUuid getClassLoaderId()

Returns:

Task local class loader id.

getDeploymentMode

public GridDeploymentMode getDeploymentMode()

Returns:

Deployment mode.

isDynamicSiblings

public boolean isDynamicSiblings()

Returns true if siblings list is dynamic, i.e. task is continuous.

Returns:

True if siblings list is dynamic.

getLoaderParticipants

public Map<UUID,GridUuid> getLoaderParticipants()

Returns:

Node class loader participant map.

isForceLocalDeployment

public boolean isForceLocalDeployment()

Returns:

Returns true if deployment should always be used.

topology

@Nullable
public Collection<UUID> topology()

Returns:

Topology.

isSessionFullSupport

public boolean isSessionFullSupport()

Returns:

True if session attributes are enabled.

isInternal

public boolean isInternal()

Returns:

True if internal job.

clone

public GridTcpCommunicationMessageAdapter clone()

Specified by:

clone in class GridTcpCommunicationMessageAdapter

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Specified by:

clone0 in class GridTcpCommunicationMessageAdapter

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Specified by:

writeTo in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Specified by:

readFrom in class GridTcpCommunicationMessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Specified by:

directType in class GridTcpCommunicationMessageAdapter

Returns:

Message type.

toString

public String toString()

Overrides:

toString in class Object