org.kepler.job

Class JobManager

java.lang.Object

org.kepler.job.JobManager

public class JobManager
extends java.lang.Object

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobManager()

Method Summary

Modifier and Type	Method and Description
protected boolean	delete(java.lang.String jobID) delete a job from queue
java.lang.String	getID()
protected void	selectJobManager(java.lang.String jobmanager, java.lang.String target, java.lang.String binPath) Choose a jobmanager for execution jobmanager can be which is supported at that time: Condor target is either "localhost" or "user@host" is the machine where the jobmanager is running is the full path to the jobmanager commands on that machine, or "" or null if they are in the default path if "'jobmanager'Support" class cannot be instantiated, a JobException is thrown
protected JobStatusInfo	status(java.lang.String jobID) Check the status of the job
protected JobStatusInfo	status(java.lang.String jobID, int numTasks) Check the status of the job and tasks if numTasks>0
protected java.lang.String	submit(Job job, boolean overwrite, java.lang.String options) Submit a job, called from Job.submit(); boolean overwrite indicates whether old files that exist on the same directory should be removed before staging new files.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobManager

protected JobManager()

Method Detail

getID

public java.lang.String getID()

selectJobManager

protected void selectJobManager(java.lang.String jobmanager,
                                java.lang.String target,
                                java.lang.String binPath)
                         throws JobException

Choose a jobmanager for execution jobmanager can be which is supported at that time: Condor target is either "localhost" or "user@host" is the machine where the jobmanager is running is the full path to the jobmanager commands on that machine, or "" or null if they are in the default path if "'jobmanager'Support" class cannot be instantiated, a JobException is thrown

Throws:

JobException

submit

protected java.lang.String submit(Job job,
                                  boolean overwrite,
                                  java.lang.String options)
                           throws JobException

Submit a job, called from Job.submit(); boolean overwrite indicates whether old files that exist on the same directory should be removed before staging new files. As long jobIDs are not really unique, this is worth to be true. options can be a special options string for the actual jobmanager.

Throws:

JobException

status

protected JobStatusInfo status(java.lang.String jobID)
                        throws JobException

Check the status of the job

Throws:

JobException

status

protected JobStatusInfo status(java.lang.String jobID,
                               int numTasks)
                        throws JobException

Check the status of the job and tasks if numTasks>0

Throws:

JobException

delete

protected boolean delete(java.lang.String jobID)
                  throws JobException

delete a job from queue

Throws:

JobException