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

Class GridJobProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.job.GridJobProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridJobProcessor
extends GridProcessorAdapter

Responsible for all grid job execution and communication.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	GridJobProcessor.PartitionsReservation

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field	Description
static String	ACTIVE	Active jobs metric name.
static String	CANCELED	Canceled jobs metric name.
static String	COMPUTE_JOB_WORKER_INTERRUPT_TIMEOUT	Distributed property that defines the timeout for interrupting the worker after cancellation in mills.
static int	DFLT_JOBS_HISTORY_SIZE
static String	EXECUTION_TIME	Total jobs execution time metric name.
static String	FINISHED	Finished jobs metric name.
static String	JOBS_METRICS	Metrics prefix.
static String	JOBS_VIEW
static String	JOBS_VIEW_DESC
static String	REJECTED	Rejected jobs metric name.
static String	STARTED	Started jobs metric name.
static String	WAITING	Waiting jobs metric name.
static String	WAITING_TIME	Total jobs waiting time metric name.

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
GridJobProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
@Nullable GridJobWorker	activeJob(IgniteUuid jobId)	Gets active job.
void	cancelJob(@Nullable IgniteUuid sesId, @Nullable IgniteUuid jobId, boolean sys)
long	computeJobWorkerInterruptTimeout()
GridDeployment	currentDeployment()	Returns current deployment.
String	currentTaskName()	Gets name task executed by current thread.
int	currentTaskNameHash()	Gets hash of task name executed by current thread.
void	currentTaskSession(GridJobSessionImpl ses)	Callback from job worker to set current task session for execution.
void	handleCollisions()	Handles collisions.
boolean	internal()
Map<ComputeJobStatusEnum,Long>	jobStatuses(IgniteUuid sesId)
void	masterLeaveLocal(IgniteUuid sesId)	Notify processor that master leave aware handler must be invoked on all jobs with the given session ID.
void	onChangeTaskAttributes(IgniteUuid sesId, IgniteUuid jobId, Map<?,?> attrs)	Callback on changing task attributes.
void	onKernalStop(boolean cancel)	Callback to notify that kernal is about to stop.
void	printMemoryStats()	Prints memory statistics (sizes of internal structures, etc.).
void	processJobExecuteRequest(ClusterNode node, GridJobExecuteRequest req)
Collection<ComputeJobSibling>	requestJobSiblings(ComputeTaskSession ses)
void	setAttributes(GridJobSessionImpl ses, Map<?,?> attrs)
void	start()	Starts grid component.
void	stop(boolean cancel)	Stops grid component.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onReconnected, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Field Detail

JOBS_VIEW

public static final String JOBS_VIEW

See Also:

Constant Field Values

JOBS_VIEW_DESC

public static final String JOBS_VIEW_DESC

See Also:

Constant Field Values

DFLT_JOBS_HISTORY_SIZE

public static final int DFLT_JOBS_HISTORY_SIZE

See Also:

IgniteSystemProperties.IGNITE_JOBS_HISTORY_SIZE, Constant Field Values

JOBS_METRICS

public static final String JOBS_METRICS

Metrics prefix.

STARTED

public static final String STARTED

Started jobs metric name.

See Also:

Constant Field Values

ACTIVE

public static final String ACTIVE

Active jobs metric name.

See Also:

Constant Field Values

WAITING

public static final String WAITING

Waiting jobs metric name.

See Also:

Constant Field Values

CANCELED

public static final String CANCELED

Canceled jobs metric name.

See Also:

Constant Field Values

REJECTED

public static final String REJECTED

Rejected jobs metric name.

See Also:

Constant Field Values

FINISHED

public static final String FINISHED

Finished jobs metric name.

See Also:

Constant Field Values

EXECUTION_TIME

public static final String EXECUTION_TIME

Total jobs execution time metric name.

See Also:

Constant Field Values

WAITING_TIME

public static final String WAITING_TIME

Total jobs waiting time metric name.

See Also:

Constant Field Values

COMPUTE_JOB_WORKER_INTERRUPT_TIMEOUT

public static final String COMPUTE_JOB_WORKER_INTERRUPT_TIMEOUT

Distributed property that defines the timeout for interrupting the worker after cancellation in mills.

See Also:

Constant Field Values

Constructor Detail

GridJobProcessor

public GridJobProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

stop

public void stop(boolean cancel)

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

activeJob

@Nullable
public @Nullable GridJobWorker activeJob(IgniteUuid jobId)

Gets active job.

Parameters:

jobId - Job ID.

Returns:

Active job.

internal

public boolean internal()

Returns:

True if running internal task.

setAttributes

public void setAttributes(GridJobSessionImpl ses,
                          Map<?,?> attrs)
                   throws IgniteCheckedException

Parameters:

ses - Session.

attrs - Attributes.

Throws:

IgniteCheckedException - If failed.

requestJobSiblings

public Collection<ComputeJobSibling> requestJobSiblings(ComputeTaskSession ses)
                                                 throws IgniteCheckedException

Parameters:

ses - Session.

Returns:

Siblings.

Throws:

IgniteCheckedException - If failed.

masterLeaveLocal

public void masterLeaveLocal(IgniteUuid sesId)

Notify processor that master leave aware handler must be invoked on all jobs with the given session ID.

Parameters:

sesId - Session ID.

cancelJob

public void cancelJob(@Nullable
                      @Nullable IgniteUuid sesId,
                      @Nullable
                      @Nullable IgniteUuid jobId,
                      boolean sys)

Parameters:

sesId - Session ID.

jobId - Job ID.

sys - System flag.

handleCollisions

public void handleCollisions()

Handles collisions.

In most cases this method should be called from main read lock to avoid jobs activation after node stop has started.

processJobExecuteRequest

public void processJobExecuteRequest(ClusterNode node,
                                     GridJobExecuteRequest req)

Parameters:

node - Node.

req - Request.

currentTaskSession

public void currentTaskSession(GridJobSessionImpl ses)

Callback from job worker to set current task session for execution.

Parameters:

ses - Session.

currentTaskNameHash

public int currentTaskNameHash()

Gets hash of task name executed by current thread.

Returns:

Task name hash or 0 if security is disabled.

currentTaskName

public String currentTaskName()

Gets name task executed by current thread.

Returns:

Task name or null if security is disabled.

currentDeployment

public GridDeployment currentDeployment()

Returns current deployment.

Returns:

Deployment.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridProcessorAdapter

onChangeTaskAttributes

public void onChangeTaskAttributes(IgniteUuid sesId,
                                   IgniteUuid jobId,
                                   Map<?,?> attrs)

Callback on changing task attributes.

Parameters:

sesId - Session ID.

jobId - Job ID.

attrs - Changed attributes.

jobStatuses

public Map<ComputeJobStatusEnum,Long> jobStatuses(IgniteUuid sesId)

Parameters:

sesId - Task session ID.

Returns:

Job statistics for the task. Mapping: Job status -> count of jobs.

computeJobWorkerInterruptTimeout

public long computeJobWorkerInterruptTimeout()

Returns:

Interruption timeout of workers (in millis) after cancel is called.