org.apache.ignite.internal

Class GridJobExecuteRequest

java.lang.Object

org.apache.ignite.plugin.extensions.communication.MessageAdapter

org.apache.ignite.internal.GridJobExecuteRequest

All Implemented Interfaces:

Serializable, GridTaskMessage

public class GridJobExecuteRequest
extends MessageAdapter
implements GridTaskMessage

Job execution request.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

MessageAdapter.Type

Field Summary

Fields inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

reader, readState

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
byte	directType() Gets message type.
String	getCheckpointSpi()
IgniteUuid	getClassLoaderId()
long	getCreateTime() Gets this instance creation time.
DeploymentMode	getDeploymentMode()
ComputeJob	getJob()
Map<? extends Serializable,? extends Serializable>	getJobAttributes()
byte[]	getJobAttributesBytes()
byte[]	getJobBytes()
IgniteUuid	getJobId()
Map<UUID,IgniteUuid>	getLoaderParticipants()
Map<Object,Object>	getSessionAttributes()
byte[]	getSessionAttributesBytes()
IgniteUuid	getSessionId()
Collection<ComputeJobSibling>	getSiblings()
byte[]	getSiblingsBytes()
long	getStartTaskTime()
UUID	getSubjectId()
String	getTaskClassName()
String	getTaskName()
long	getTimeout()
String	getUserVersion()
boolean	isDynamicSiblings() Returns true if siblings list is dynamic, i.e. task is continuous.
boolean	isForceLocalDeployment()
boolean	isInternal()
boolean	isSessionFullSupport()
boolean	readFrom(ByteBuffer buf) Reads this message from provided byte buffer.
Collection<UUID>	topology()
String	toString()
boolean	writeTo(ByteBuffer buf, MessageWriter writer) Writes this message to provided byte buffer.

Methods inherited from class org.apache.ignite.plugin.extensions.communication.MessageAdapter

setReader, skipRecovery

Methods inherited from class java.lang.Object

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

Constructor Detail

GridJobExecuteRequest

public GridJobExecuteRequest()

No-op constructor to support Externalizable interface.

GridJobExecuteRequest

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

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.

subjId - Subject ID.

Method Detail

getSessionId

public IgniteUuid getSessionId()

Specified by:

getSessionId in interface GridTaskMessage

Returns:

Session ID.

getJobId

public IgniteUuid 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 ComputeJob 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<ComputeJobSibling> 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 IgniteUuid getClassLoaderId()

Returns:

Task local class loader id.

getDeploymentMode

public DeploymentMode 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,IgniteUuid> 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.

getSubjectId

public UUID getSubjectId()

Returns:

Subject ID.

writeTo

public boolean writeTo(ByteBuffer buf,
              MessageWriter writer)

Writes this message to provided byte buffer.

Specified by:

writeTo in class MessageAdapter

Parameters:

buf - Byte buffer.

writer - Writer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Reads this message from provided byte buffer.

Specified by:

readFrom in class MessageAdapter

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Gets message type.

Specified by:

directType in class MessageAdapter

Returns:

Message type.

toString

public String toString()

Overrides:

toString in class Object