Field Summary |
|
final public static int | CLEANUP_JOB Denotes a cleanup job, that removes the files that from the remote
working directories of the remote sites. |
final public static int | COMPUTE_JOB Denotes a compute job. |
final public static int | CREATE_DIR_JOB Denotes a job that creates directories at the remote pools. |
final public static int | INTER_POOL_JOB Denotes a job that transfers the output of a compute node to the site
where the child compute node is to be generated. |
final public static int | REPLICA_REG_JOB Denotes a job that registers in the replica mechanism the materialized
files. |
final public static int | STAGED_COMPUTE_JOB Denotes a job for which the executable has been staged as part of the
workflow. |
final public static int | STAGE_IN_JOB Denotea a job that is used to stage in the input files for a compute job. |
final public static int | STAGE_OUT_JOB Denotes a job that transfers the date generated by a compute job to the
output pool specified by the user. |
final public static int | UNASSIGNED_JOB Denotes a job that does not fall into the other categories. |
public String | condorUniverse The universe in which the job has to be executed. |
public Condor | condorVariables For Condor Namespace. |
public Dagman | dagmanVariables The DAGMAN namespace profile variable holding the dagman profiles. |
public String | dvName The name of the derivation in Chimera that generated the job. |
public String | dvNamespace The namespace to which the derivation is bound. |
public String | dvVersion The version of the derivation. |
public ENV | envVariables To accomodate the environment variables which might needed to be set. |
public String | executable The path of the executable on the machine at which the job is executed. |
public String | executionPool The pool on which this job has been decided to be executed by the
Interpool Engine. |
public Globus | globusRSL The namespace object containing the globus rsl attributes which the user
specifies in the dax, or the pool file or the properties file. |
public String | globusScheduler The globus Scheduler for the job. |
public Hints | hints To accomodate all the hints that maybe passed through the DAX. |
public Set | inputFiles Contains the input files for the submit file. |
public int | jobClass The type of the job. |
public String | jobID Identifies of which VDS Super Node is a job associated with. |
public String | jobName The name of the job. |
public int | level Identifies the level of the job in the dax. |
public String | logicalId The logical id of the job as referred to in the dax. |
public String | logicalName The logical name of the transformation which is executed as a part of
this job. |
public String | namespace The namespace to which the transformation is bound. |
public Set | outputFiles Contains the output files for the submit file. |
public String | stdErr File which contains standard error. |
public String | stdIn File which contains stdin (keyboard input). |
public String | stdOut File which contains stdout. |
public String | strargs The arguements for the job. |
public VDS | vdsNS The VDS namespace variable. |
public String | version The version of the transformation. |
Method Summary |
|
public void | addInputFile(PegasusFile file) Adds an input file to the underlying collection of input files
associated with the job. |
public void | addOutputFile(PegasusFile file) Adds an output file to the underlying collection of output files
associated with the job. |
public Object | clone() Returns a new copy of the Object. |
public boolean | equals(Object obj) Checks if an object is similar to the one referred to by this class.
We compare the primary key to determine if it is the same or not.
Parameters: obj - the object for which equalsto is applied. |
public String | getArguments() Returns the argument string with which the job has to be invoked. |
public String | getCompleteDVName() Constructs the fully qualified name of the corresponding derivation used
to generate this job in Chimera including the namespace and version. |
public String | getCompleteTCName() Constructs the fully qualified name of a transformation with
which to query the TC, including the namespace and version. |
protected String | getDOTColor() Returns the color with which DOT should color the node representing the
job. |
public String | getDVName() Returns the name of the underlying derivation. |
public String | getDVNamespace() Returns the namespace of the underlying derivation. |
public String | getDVVersion() Returns the version of the underlying derivation. |
public String | getID() Returns the ID associated with the job. |
public Set | getInputFiles() Returns the set of input files associated with the job. |
public String | getJobManager() Returnss the remote jobmanager on which the job has to run. |
public int | getJobType() Returns the type of the job. |
public String | getJobTypeDescription() Gets the textual description of the type associated with the job. |
public String | getJobTypeDescription(int type) Gets the textual description of the type that can be associated
with a job.
Parameters: type - the type of the job. |
public int | getLevel() Returns the level associated with the job. |
public String | getLogicalID() Returns the logical id of the job. |
public String | getName() Returns the name of the job. |
public Set | getOutputFiles() Returns the set of output files associated with the job. |
public String | getPreScriptArguments() Returns the arguments to the prescript for the job if set. |
public String | getPreScriptPath() Returns the path to the prescript for the job if set. |
public String | getRemoteExecutable() Returns the path of the underlying executable on the remote grid site. |
public String | getSiteHandle() Returns the handle of the site where the job is scheduled. |
public String | getStagedExecutableBaseName() Returns the basename for the staged executable corresponding to the
job. |
public static String | getStagedExecutableBaseName(String txNamespace, String txName, String txVersion) Returns the basename for the staged executable corresponding to the
job. |
public String | getStdErr() Returns the file to which the stderr of the job is written to. |
public String | getStdIn() Returns the file from which the stdin is picked up. |
public String | getStdOut() Returns the file to which the stdout of the job is written to. |
public String | getTXName() Returns the name of the underlying transformation. |
public String | getTXNamespace() Returns the namespace of the underlying transformation. |
public String | getTXVersion() Returns the version of the underlying transformation. |
public String | getUniverse() Returns the universe associated with the job. |
public String | getVDSSuperNode() Returns the name of the compute job of VDS supernode containing this job. |
public boolean | isMPIJob() Returns a boolean value denoting whether the job is MPI or not. |
public void | mergeProfiles(SubInfo job) Merges profiles from another job to this job in a controlled fashion.
The merging of the profile is dependant upon the namespace to which it
belongs. |
public void | resetProfiles() Resets all the profiles associated with the job. |
public boolean | runInWorkDirectory() Returns whether a job should be run in the work directory or not.
If a job is not run in the work directory, then it should be run
in the submit directory. |
public void | setArguments(String arguments) Sets the argument string with which the job has to be invoked. |
public void | setDVName(String name) Sets the derivation name of the underlying derivation. |
public void | setDVNamespace(String ns) Sets the derivation namespace to be associated with the job. |
public void | setDVVersion(String vs) Sets the version of the underlying derivation. |
public void | setDerivation(String ns, String name, String vs) Sets the various attributes of underlying derivation. |
public void | setInputFiles(Set ipFiles) Sets the input files associated with the job. |
public void | setJobManager(String jobmanager) Sets the remote jobmanager on which the job has to run. |
public void | setJobType(int type) Sets the type of the job. |
public void | setLevel(int value) Sets the level for the job. |
public void | setLogicalID(String id) Setter method to set the logical id of the job. |
public void | setName(String name) Setter method to set the name of the job. |
public void | setOutputFiles(Set opFiles) Sets the output files associated with the job. |
public void | setPreScript(String path) It sets the prescript for the job. |
public void | setPreScript(String path, String arguments) It sets the prescript for the job. |
public void | setRemoteExecutable(String path) Sets the path to the executable on the remote grid site. |
public void | setSiteHandle(String site) |
public void | setStdErr(String fileName) Sets the file to which the stderr of the job needs to be written to
at the remote grid site. |
public void | setStdIn(String fileName) Sets the file to from which to pick up the stdin for the job. |
public void | setStdOut(String fileName) Sets the file to which the stdout of the job needs to be written to
at the remote grid site. |
public void | setTXName(String name) Sets the transformation name of the underlying transformation. |
public void | setTXNamespace(String ns) Sets the transformation namespace to be associated with the job. |
public void | setTXVersion(String vs) Sets the version of the underlying transformation. |
public void | setTransformation(String ns, String name, String vs) Sets the various attributes of underlying transformation. |
public void | setUniverse(String universe) Set the universe associated with the job. |
public void | setVDSSuperNode(String name) Setter method to the name of the compute job of VDS supernode containing
this job. |
public String | toDOT() Returns the DOT description of the object. |
public void | toDOT(Writer stream, String indent) Returns the DOT description of the object. |
public String | toString() Returns a textual description of the object. |
public boolean | typeInRange(int type) Returns whether the job type value for the job is in range or not.
Parameters: type - the job type. |
public void | updateProfiles(TransformationCatalogEntry entry) Updates all the profile namespaces with the information associated in
the transformation catalog for this job.
It ends up updating already existing information, and adds supplemental
new information if present in the transformation catalog.
The method does not explicitly check whehter the data object passed refers
to this job or not. |
public void | updateProfiles(PegasusProperties properties) Updates all the profile namespaces with the information specified by the
user in the properties file, that apply to this job.
It ends up updating already existing information, and adds supplemental
new information if present in the properties file.
The method does not explicitly check whehter the data object passed refers
to this job or not. |
public void | updateProfiles(List profiles) Updates all the profile namespaces with the information specified in
list of profile objects passed. |