org.gridgain.grid.kernal

Class GridJobSiblingImpl

java.lang.Object

org.gridgain.grid.util.lang.GridMetadataAwareAdapter

org.gridgain.grid.kernal.GridJobSiblingImpl

All Implemented Interfaces:

Externalizable, Serializable, GridComputeJobSibling, GridMetadataAware

public class GridJobSiblingImpl
extends GridMetadataAwareAdapter
implements GridComputeJobSibling, Externalizable

This class provides implementation for job sibling.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridJobSiblingImpl()
GridJobSiblingImpl(GridUuid sesId, GridUuid jobId, UUID nodeId, GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Sends a request to cancel this sibling.
GridUuid	getJobId() Gets ID of this grid job sibling.
boolean	isJobDone()
Object	jobTopic()
UUID	nodeId()
void	nodeId(UUID nodeId)
void	onJobDone()
void	readExternal(ObjectInput in)
Object	taskTopic()
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.gridgain.grid.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, readExternalMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Constructor Detail

GridJobSiblingImpl

public GridJobSiblingImpl()

GridJobSiblingImpl

public GridJobSiblingImpl(GridUuid sesId,
                  GridUuid jobId,
                  UUID nodeId,
                  GridKernalContext ctx)

Parameters:

sesId - Task session ID.

jobId - Job ID.

nodeId - ID of the node where this sibling was sent for execution.

ctx - Managers registry.

Method Detail

getJobId

public GridUuid getJobId()

Gets ID of this grid job sibling. Note that ID stays constant throughout job life time, even if a job gets failed over to another node.

Specified by:

getJobId in interface GridComputeJobSibling

Returns:

Job ID.

nodeId

public UUID nodeId()

Returns:

Node ID.

nodeId

public void nodeId(UUID nodeId)

Parameters:

nodeId - Node where this sibling is executing.

isJobDone

public boolean isJobDone()

Returns:

True if job has finished.

onJobDone

public void onJobDone()

taskTopic

public Object taskTopic()

Returns:

Communication topic for receiving.

jobTopic

public Object jobTopic()

Returns:

Communication topic for sending.

cancel

public void cancel()
            throws GridException

Sends a request to cancel this sibling.

Specified by:

cancel in interface GridComputeJobSibling

Throws:

GridException - If cancellation message could not be sent.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object