Package org.apache.ignite.internal.processors.job

Class GridJobWorker

java.lang.Object

org.apache.ignite.internal.util.worker.GridWorker

org.apache.ignite.internal.processors.job.GridJobWorker

All Implemented Interfaces:

Runnable, GridTimeoutObject, WorkProgressDispatcher

public class GridJobWorker
extends GridWorker
implements GridTimeoutObject

Job worker.

Field Summary

Fields inherited from class org.apache.ignite.internal.util.worker.GridWorker

isCancelled

Method Summary

Modifier and Type	Method	Description
protected void	body()	The implementation should provide the execution body for this runnable.
void	cancel()	Cancels this runnable.
void	cancel(boolean sys)
long	endTime()
void	execute()	Executes the job.
String	executorName()
long	getCreateTime()
GridDeployment	getDeployment()
long	getFinishTime()
@Nullable ComputeJob	getJob()	Gets deployed job or null of job could not be deployed.
ComputeJobContext	getJobContext()
IgniteUuid	getJobId()
GridReservable	getPartsReservation()
GridJobSessionImpl	getSession()
long	getStartTime()
ClusterNode	getTaskNode()
int	hashCode()
boolean	held()
boolean	hold()	Sets halt flags.
boolean	isFinishing()	Gets job finishing state.
boolean	isInternal()
boolean	isStarted()
boolean	isTimedOut()
protected void	onCancel(boolean firstCancelRequest)	Callback on runner cancellation.
protected void	onCancelledBeforeWorkerScheduled()	Callback on special case, when task is cancelled before is has been scheduled.
void	onStopping()	Callback for whenever grid is stopping.
void	onTimeout()	Timeout callback.
IgniteUuid	timeoutId()
String	toString()

Methods inherited from class org.apache.ignite.internal.util.worker.GridWorker

blockingSectionBegin, blockingSectionEnd, cleanup, heartbeatTs, igniteInstanceName, isCancelled, isDone, join, name, onIdle, run, runner, updateHeartbeat

Methods inherited from class java.lang.Object

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

Method Detail

getJob

@Nullable
public @Nullable ComputeJob getJob()

Gets deployed job or null of job could not be deployed.

Returns:

Deployed job.

getDeployment

public GridDeployment getDeployment()

Returns:

Deployed task.

getCreateTime

public long getCreateTime()

Returns:

Create time.

getStartTime

public long getStartTime()

Returns:

Start time.

getFinishTime

public long getFinishTime()

Returns:

Finish time.

isStarted

public boolean isStarted()

Returns:

Is started.

getPartsReservation

public GridReservable getPartsReservation()

Returns:

Grid reservable resource.

getJobId

public IgniteUuid getJobId()

Returns:

Unique job ID.

getJobContext

public ComputeJobContext getJobContext()

Returns:

Job context.

getSession

public GridJobSessionImpl getSession()

Returns:

Session.

isFinishing

public boolean isFinishing()

Gets job finishing state.

Returns:

true if job is being finished after execution and false otherwise.

getTaskNode

public ClusterNode getTaskNode()

Returns:

Parent task node ID.

endTime

public long endTime()

Specified by:

endTime in interface GridTimeoutObject

Returns:

End time.

timeoutId

public IgniteUuid timeoutId()

Specified by:

timeoutId in interface GridTimeoutObject

Returns:

ID of the object.

isTimedOut

public boolean isTimedOut()

Returns:

True if job is timed out.

isInternal

public boolean isInternal()

Returns:

True if parent task is internal or Visor-related.

onTimeout

public void onTimeout()

Timeout callback.

Specified by:

onTimeout in interface GridTimeoutObject

onStopping

public void onStopping()

Callback for whenever grid is stopping.

held

public boolean held()

Returns:

True if job was halted.

hold

public boolean hold()

Sets halt flags.

body

protected void body()

The implementation should provide the execution body for this runnable.

Specified by:

body in class GridWorker

execute

public void execute()

Executes the job.

cancel

public void cancel()

Cancels this runnable.

Overrides:

cancel in class GridWorker

cancel

public void cancel(boolean sys)

Parameters:

sys - System flag.

executorName

public String executorName()

Returns:

Custom executor name.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

onCancel

protected void onCancel(boolean firstCancelRequest)

Callback on runner cancellation.

Overrides:

onCancel in class GridWorker

Parameters:

firstCancelRequest - Flag indicating that worker cancellation was requested for the first time.

onCancelledBeforeWorkerScheduled

protected void onCancelledBeforeWorkerScheduled()

Callback on special case, when task is cancelled before is has been scheduled.

Overrides:

onCancelledBeforeWorkerScheduled in class GridWorker

toString

public String toString()

Overrides:

toString in class GridWorker