edu.isi.pegasus.planner.classes
Class DAGJob

java.lang.Object
  edu.isi.pegasus.planner.classes.Data
      edu.isi.pegasus.planner.classes.Job
          edu.isi.pegasus.planner.classes.DAGJob

All Implemented Interfaces:

GraphNodeContent, Cloneable

public class DAGJob
extends Job

This is a data class that stores the contents of the DAG job in a DAX conforming to schema 3.0 or higher.

Version:

$Revision: 3415 $

Author:

Karan Vahi

Field Summary

static String	JOB_PREFIX The prefix to be attached for the DAX jobs
private String	mDAGFile The DAG File that the job refers to.
private String	mDAGLFN The DAG LFN.
private String	mDirectory The directory in which the DAG needs to execute.

Fields inherited from class edu.isi.pegasus.planner.classes.Job

CHMOD_JOB, CLEANUP_JOB, COMPUTE_JOB, condorUniverse, condorVariables, CREATE_DIR_JOB, DAG_JOB, dagmanVariables, DAX_JOB, dvName, dvNamespace, dvVersion, envVariables, executable, executionPool, globusRSL, globusScheduler, hints, inputFiles, INTER_POOL_JOB, jobClass, jobID, jobName, level, logicalId, logicalName, namespace, outputFiles, REPLICA_REG_JOB, STAGE_IN_JOB, STAGE_IN_WORKER_PACKAGE_JOB, STAGE_OUT_JOB, stdErr, stdIn, stdOut, strargs, UNASSIGNED_JOB, vdsNS, version

Fields inherited from class edu.isi.pegasus.planner.classes.Data

mLogger, mLogMsg

Constructor Summary

DAGJob()
The default constructor.

DAGJob(Job job)
The overloaded construct that constructs a DAG job by wrapping around the Job job.

Method Summary

Object	clone() Returns a new copy of the Object.
String	generateName(String prefix) Generates a name for the job that serves as the primary id for the job
String	getDAGFile() Returns the DAGFile the job refers to.
String	getDAGLFN() Returns the lfn for the DAGFile the job refers to.
String	getDirectory() Returns the directory the job refers to.
void	setDAGFile(String file) Sets the DAG file
void	setDAGLFN(String lfn) Sets the DAG file LFN
void	setDirectory(String directory) Sets the directory in which the dag needs to execute.
String	toString() Returns a textual description of the DAG Job.

Methods inherited from class edu.isi.pegasus.planner.classes.Job

addCredentialType, addCredentialType, addInputFile, addNotification, addNotifications, addNotifications, addOutputFile, addProfile, computeRuntime, equals, getArguments, getCompleteDVName, getCompleteTCName, getCredentialTypes, getDAXID, getDOTColor, getDVName, getDVNamespace, getDVVersion, getGridGatewayJobType, getID, getInputFiles, getJobManager, getJobType, getJobTypeDescription, getJobTypeDescription, getLevel, getLogicalID, getName, getNotifications, getNotifications, getOutputFiles, getPreScriptArguments, getPreScriptPath, getRemoteExecutable, getRuntime, getSiteHandle, getStagedExecutableBaseName, getStagedExecutableBaseName, getStagingSiteHandle, getStdErr, getStdIn, getStdOut, getTXName, getTXNamespace, getTXVersion, getUniverse, getVDSSuperNode, isMPIJob, mergeProfiles, resetCredentialTypes, resetNotifications, resetProfiles, runInWorkDirectory, setArguments, setDerivation, setDVName, setDVNamespace, setDVVersion, setExecutableStagingForJob, setInputFiles, setJobManager, setJobType, setLevel, setLogicalID, setName, setOutputFiles, setPreScript, setPreScript, setRemoteExecutable, setRuntime, setRuntime, setSiteHandle, setStagingSiteHandle, setStdErr, setStdIn, setStdOut, setTransformation, setTXName, setTXNamespace, setTXVersion, setTypeRecursive, setUniverse, setVDSSuperNode, toDOT, toDOT, typeInRange, typeRecursive, updateProfiles, updateProfiles, updateProfiles, updateProfiles, userExecutablesStagedForJob

Methods inherited from class edu.isi.pegasus.planner.classes.Data

setToString, vectorToString

Methods inherited from class java.lang.Object

finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

JOB_PREFIX

public static final String JOB_PREFIX

The prefix to be attached for the DAX jobs

See Also:

Constant Field Values

mDAGLFN

private String mDAGLFN

The DAG LFN.

mDAGFile

private String mDAGFile

The DAG File that the job refers to.

mDirectory

private String mDirectory

The directory in which the DAG needs to execute.

Constructor Detail

DAGJob

public DAGJob()

The default constructor.

DAGJob

public DAGJob(Job job)

The overloaded construct that constructs a DAG job by wrapping around the Job job.

Parameters:

job - the original job description.

Method Detail

setDAGLFN

public void setDAGLFN(String lfn)

Sets the DAG file LFN

Parameters:

lfn - the LFN of the DAG file.

getDAGLFN

public String getDAGLFN()

Returns the lfn for the DAGFile the job refers to.

Returns:

the lfn

setDAGFile

public void setDAGFile(String file)

Sets the DAG file

Parameters:

file - the path to the DAG file.

getDAGFile

public String getDAGFile()

Returns the DAGFile the job refers to.

Returns:

dag file

setDirectory

public void setDirectory(String directory)

Sets the directory in which the dag needs to execute.

Overrides:

setDirectory in class Job

Parameters:

directory - the directory where dag needs to execute

getDirectory

public String getDirectory()

Returns the directory the job refers to.

Overrides:

getDirectory in class Job

Returns:

the directory.

generateName

public String generateName(String prefix)

Generates a name for the job that serves as the primary id for the job

Parameters:

prefix - any prefix that needs to be applied while constructing the job name

Returns:

the id for the job

toString

public String toString()

Returns a textual description of the DAG Job.

Overrides:

toString in class Job

Returns:

the textual description.

clone

public Object clone()

Returns a new copy of the Object. The implementation is faulty. There is a shallow copy for the profiles. That is the clone retains references to the original object.

Overrides:

clone in class Job

Returns:

Object