| Package | Description |
|---|---|
| org.kepler.job |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
JobManager.delete(java.lang.String jobID)
delete a job from queue
|
boolean |
Job.deleteFromQueue()
Remove job from the queue (either running or waiting)
|
static JobManager |
JobManagerFactory.get(java.lang.String supportname,
java.lang.String target,
java.lang.String binPath)
return an existing job manager OR create one now
|
java.lang.String |
JobSupportCondor.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for Condor. return: the command for submission
|
java.lang.String |
JobSupportSGE.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for SGE return: the command for submission
|
java.lang.String |
JobSupportLoadLeveler.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for LoadLeveler return: the command for submission
|
java.lang.String |
JobSupportLSF.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for lsf return: the command for submission
|
java.lang.String |
JobSupportPBS.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for PBS return: the command for submission
|
java.lang.String |
JobSupportFork.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for fork return: the command for submission
|
java.lang.String |
JobSupportMoab.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for Moab
return: the command for submission
|
java.lang.String |
JobSupportNCCS.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for NCCS return: the command for submission
|
java.lang.String |
JobSupportSLURM.getSubmitCmd(java.lang.String submitFile,
java.lang.String options,
Job job)
Submit command for SLURM return: the command for submission
|
boolean |
JobSupportCondor.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true or false indicating that the
command was successful or not
|
boolean |
JobSupportSGE.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true if stdout is empty and
exitCode is 0, otherwise return false
|
boolean |
JobSupportLoadLeveler.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true or false indicating that the
command was successful or not
|
boolean |
JobSupportLSF.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true if stdout is empty and
exitCode is 0, otherwise return false
|
boolean |
JobSupportPBS.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true or false indicating that the
command was successful or not
|
boolean |
JobSupportFork.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true if stdout is empty and
exitCode is 0, otherwise return false
|
boolean |
JobSupportMoab.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command.
|
boolean |
JobSupportNCCS.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true or false indicating that the
command was successful or not
|
boolean |
JobSupportSLURM.parseDeleteOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of delete command. return: true or false indicating that the
command was successful or not
|
JobStatusInfo |
JobSupportCondor.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info. return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportSGE.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportLoadLeveler.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportLSF.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportPBS.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportFork.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportMoab.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info
|
JobStatusInfo |
JobSupportNCCS.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
JobStatusInfo |
JobSupportSLURM.parseStatusOutput(java.lang.String jobID,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of status check command and get status info return: a
JobStatusInfo object, or throws an JobException with the error output
|
java.lang.String |
JobSupportCondor.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID. return String
jobID on success throws JobException at failure (will contain the error
stream or output stream)
|
java.lang.String |
JobSupportSGE.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportLoadLeveler.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportLSF.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportPBS.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportFork.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportMoab.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID
return String jobID on success
throws JobException at failure (will contain the error stream or output stream)
|
java.lang.String |
JobSupportNCCS.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
java.lang.String |
JobSupportSLURM.parseSubmitOutput(java.lang.String output,
java.lang.String error)
Parse output of submission and get information: jobID return String jobID
on success throws JobException at failure (will contain the error stream
or output stream)
|
TaskParallelJobStatusInfo |
JobSupportCondor.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportSGE.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportLoadLeveler.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportLSF.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportPBS.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportFork.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportMoab.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error)
Parse output of task status check command and get status info
|
TaskParallelJobStatusInfo |
JobSupportNCCS.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
TaskParallelJobStatusInfo |
JobSupportSLURM.parseTaskStatusOutput(java.lang.String jobID,
int numTasks,
int exitCode,
java.lang.String output,
java.lang.String error) |
boolean |
Job.reconnect(JobManager jobmanager)
Reconnect to a executing job.
|
protected void |
JobManager.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
|
void |
Job.setBinFile(java.lang.String binFile,
boolean isLocal)
Set file to be staged to bin path.
|
boolean |
Job.setExecutable(java.lang.String executablePath,
boolean isLocal,
java.lang.String arguments)
Set the executable for the job.
|
boolean |
Job.setInputFile(java.lang.String path,
boolean isLocal)
Set an input file for job.
|
boolean |
Job.setLocalWorkdir(java.lang.String path)
Set and create the local working directory.
|
boolean |
Job.setOtherInputFile(java.lang.String path)
Set an "other" input file for job.
|
void |
Job.setOutputFile(java.lang.String path)
Set an output file for job.
|
void |
Job.setSubmitFile(java.lang.String submitFile,
boolean isItLocal)
Give a predefined submit file for the job.
|
boolean |
Job.status()
Check the status of the job
|
protected JobStatusInfo |
JobManager.status(java.lang.String jobID)
Check the status of the job
|
protected JobStatusInfo |
JobManager.status(java.lang.String jobID,
int numTasks)
Check the status of the job and tasks if numTasks>0
|
protected java.lang.String |
JobManager.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.
|
java.lang.String |
Job.submit(JobManager jobmanager,
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.
|