com.asakusafw.yaess.core.task

Class ScriptJob<T extends ExecutionScript>

java.lang.Object

com.asakusafw.yaess.core.Job

com.asakusafw.yaess.core.task.ScriptJob<T>

Type Parameters:

T - kind of script

public class ScriptJob<T extends ExecutionScript>
extends Job

Job to execute a script.

Since:

0.2.3

Constructor Summary

Constructors

Constructor and Description
ScriptJob(T script, ExecutionScriptHandler<? super T> handler) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	execute(ExecutionMonitor monitor, ExecutionContext context) Executes this job.
Set<String>	getBlockerIds() Returns job IDs which blocks executing this job.
String	getId() Returns the ID of this job for other succeeding jobs.
String	getJobLabel() Returns the target job label.
String	getResourceId(ExecutionContext context) Returns the resource ID which this job requires in execution.
String	getServiceLabel() Returns the service label which actually executes this job.
String	getTrackingId(ExecutionContext context) Returns the tracking ID of this job.

Methods inherited from class com.asakusafw.yaess.core.Job

computeTrackingId, computeTrackingId, launch

Methods inherited from class java.lang.Object

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

Constructor Detail

ScriptJob

public ScriptJob(T script,
                 ExecutionScriptHandler<? super T> handler)

Creates a new instance.

Parameters:

script - target script

handler - the related script handler

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

execute

public void execute(ExecutionMonitor monitor,
                    ExecutionContext context)
             throws InterruptedException,
                    IOException

Description copied from class: Job

Executes this job.

Specified by:

execute in class Job

Parameters:

monitor - a progress monitor for this job

context - current execution context

Throws:

InterruptedException - if this execution is interrupted

IOException - if failed to execute this job

getServiceLabel

public String getServiceLabel()

Description copied from class: Job

Returns the service label which actually executes this job.

Specified by:

getServiceLabel in class Job

Returns:

the service label

getJobLabel

public String getJobLabel()

Description copied from class: Job

Returns the target job label.

Specified by:

getJobLabel in class Job

Returns:

the target job label

getId

public String getId()

Description copied from class: Job

Returns the ID of this job for other succeeding jobs.

Specified by:

getId in class Job

Returns:

ID of this job

getTrackingId

public String getTrackingId(ExecutionContext context)

Description copied from class: Job

Returns the tracking ID of this job.

Overrides:

getTrackingId in class Job

Parameters:

context - current execution context

Returns:

the tracking ID

getBlockerIds

public Set<String> getBlockerIds()

Description copied from class: Job

Returns job IDs which blocks executing this job. Any schedulers can execute this job only if all blocker jobs are completed.

Specified by:

getBlockerIds in class Job

Returns:

the blocker job IDs

getResourceId

public String getResourceId(ExecutionContext context)
                     throws InterruptedException,
                            IOException

Description copied from class: Job

Returns the resource ID which this job requires in execution.

Specified by:

getResourceId in class Job

Parameters:

context - current execution context

Returns:

the resource ID required in this job

Throws:

InterruptedException - if this execution is interrupted

IOException - if failed to execute this job