Java Doc for SubInfo.java in  » Workflow-Engines » pegasus-2.1.0 » org » griphyn » cPlanner » classes » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » Workflow Engines » pegasus 2.1.0 » org.griphyn.cPlanner.classes 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   org.griphyn.cPlanner.classes.Data
      org.griphyn.cPlanner.classes.SubInfo

All known Subclasses:   org.griphyn.cPlanner.classes.AggregatedJob,  org.griphyn.cPlanner.classes.GRMSJob,  org.griphyn.cPlanner.classes.TransferJob,
SubInfo
public class SubInfo extends Data implements GraphNodeContent(Code)
The object of this class holds the information to generate a submit file about one particular job making the Dag.
author:
   Karan Vahi
author:
   Gaurang Mehta
version:
   $Revision: 222 $


Field Summary
final public static  intCLEANUP_JOB
     Denotes a cleanup job, that removes the files that from the remote working directories of the remote sites.
final public static  intCOMPUTE_JOB
     Denotes a compute job.
final public static  intCREATE_DIR_JOB
     Denotes a job that creates directories at the remote pools.
final public static  intINTER_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  intREPLICA_REG_JOB
     Denotes a job that registers in the replica mechanism the materialized files.
final public static  intSTAGED_COMPUTE_JOB
     Denotes a job for which the executable has been staged as part of the workflow.
final public static  intSTAGE_IN_JOB
     Denotea a job that is used to stage in the input files for a compute job.
final public static  intSTAGE_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  intUNASSIGNED_JOB
     Denotes a job that does not fall into the other categories.
public  StringcondorUniverse
     The universe in which the job has to be executed.
public  CondorcondorVariables
     For Condor Namespace.
public  DagmandagmanVariables
     The DAGMAN namespace profile variable holding the dagman profiles.
public  StringdvName
     The name of the derivation in Chimera that generated the job.
public  StringdvNamespace
     The namespace to which the derivation is bound.
public  StringdvVersion
     The version of the derivation.
public  ENVenvVariables
     To accomodate the environment variables which might needed to be set.
public  Stringexecutable
     The path of the executable on the machine at which the job is executed.
public  StringexecutionPool
     The pool on which this job has been decided to be executed by the Interpool Engine.
public  GlobusglobusRSL
     The namespace object containing the globus rsl attributes which the user specifies in the dax, or the pool file or the properties file.
public  StringglobusScheduler
     The globus Scheduler for the job.
public  Hintshints
     To accomodate all the hints that maybe passed through the DAX.
public  SetinputFiles
     Contains the input files for the submit file.
public  intjobClass
     The type of the job.
public  StringjobID
     Identifies of which VDS Super Node is a job associated with.
public  StringjobName
     The name of the job.
public  intlevel
     Identifies the level of the job in the dax.
public  StringlogicalId
     The logical id of the job as referred to in the dax.
public  StringlogicalName
     The logical name of the transformation which is executed as a part of this job.
public  Stringnamespace
     The namespace to which the transformation is bound.
public  SetoutputFiles
     Contains the output files for the submit file.
public  StringstdErr
     File which contains standard error.
public  StringstdIn
     File which contains stdin (keyboard input).
public  StringstdOut
     File which contains stdout.
public  Stringstrargs
     The arguements for the job.
public  VDSvdsNS
     The VDS namespace variable.
public  Stringversion
     The version of the transformation.

Constructor Summary
public  SubInfo()
     Intialises the member variables.
public  SubInfo(SubInfo job)
     Overloaded constructor.

Method Summary
public  voidaddInputFile(PegasusFile file)
     Adds an input file to the underlying collection of input files associated with the job.
public  voidaddOutputFile(PegasusFile file)
     Adds an output file to the underlying collection of output files associated with the job.
public  Objectclone()
     Returns a new copy of the Object.
public  booleanequals(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  StringgetArguments()
     Returns the argument string with which the job has to be invoked.
public  StringgetCompleteDVName()
     Constructs the fully qualified name of the corresponding derivation used to generate this job in Chimera including the namespace and version.
public  StringgetCompleteTCName()
     Constructs the fully qualified name of a transformation with which to query the TC, including the namespace and version.
protected  StringgetDOTColor()
     Returns the color with which DOT should color the node representing the job.
public  StringgetDVName()
     Returns the name of the underlying derivation.
public  StringgetDVNamespace()
     Returns the namespace of the underlying derivation.
public  StringgetDVVersion()
     Returns the version of the underlying derivation.
public  StringgetID()
     Returns the ID associated with the job.
public  SetgetInputFiles()
     Returns the set of input files associated with the job.
public  StringgetJobManager()
     Returnss the remote jobmanager on which the job has to run.
public  intgetJobType()
     Returns the type of the job.
public  StringgetJobTypeDescription()
     Gets the textual description of the type associated with the job.
public  StringgetJobTypeDescription(int type)
     Gets the textual description of the type that can be associated with a job.
Parameters:
  type - the type of the job.
public  intgetLevel()
     Returns the level associated with the job.
public  StringgetLogicalID()
     Returns the logical id of the job.
public  StringgetName()
     Returns the name of the job.
public  SetgetOutputFiles()
     Returns the set of output files associated with the job.
public  StringgetPreScriptArguments()
     Returns the arguments to the prescript for the job if set.
public  StringgetPreScriptPath()
     Returns the path to the prescript for the job if set.
public  StringgetRemoteExecutable()
     Returns the path of the underlying executable on the remote grid site.
public  StringgetSiteHandle()
     Returns the handle of the site where the job is scheduled.
public  StringgetStagedExecutableBaseName()
     Returns the basename for the staged executable corresponding to the job.
public static  StringgetStagedExecutableBaseName(String txNamespace, String txName, String txVersion)
     Returns the basename for the staged executable corresponding to the job.
public  StringgetStdErr()
     Returns the file to which the stderr of the job is written to.
public  StringgetStdIn()
     Returns the file from which the stdin is picked up.
public  StringgetStdOut()
     Returns the file to which the stdout of the job is written to.
public  StringgetTXName()
     Returns the name of the underlying transformation.
public  StringgetTXNamespace()
     Returns the namespace of the underlying transformation.
public  StringgetTXVersion()
     Returns the version of the underlying transformation.
public  StringgetUniverse()
     Returns the universe associated with the job.
public  StringgetVDSSuperNode()
     Returns the name of the compute job of VDS supernode containing this job.
public  booleanisMPIJob()
     Returns a boolean value denoting whether the job is MPI or not.
public  voidmergeProfiles(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  voidresetProfiles()
     Resets all the profiles associated with the job.
public  booleanrunInWorkDirectory()
     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  voidsetArguments(String arguments)
     Sets the argument string with which the job has to be invoked.
public  voidsetDVName(String name)
     Sets the derivation name of the underlying derivation.
public  voidsetDVNamespace(String ns)
     Sets the derivation namespace to be associated with the job.
public  voidsetDVVersion(String vs)
     Sets the version of the underlying derivation.
public  voidsetDerivation(String ns, String name, String vs)
     Sets the various attributes of underlying derivation.
public  voidsetInputFiles(Set ipFiles)
     Sets the input files associated with the job.
public  voidsetJobManager(String jobmanager)
     Sets the remote jobmanager on which the job has to run.
public  voidsetJobType(int type)
     Sets the type of the job.
public  voidsetLevel(int value)
     Sets the level for the job.
public  voidsetLogicalID(String id)
     Setter method to set the logical id of the job.
public  voidsetName(String name)
     Setter method to set the name of the job.
public  voidsetOutputFiles(Set opFiles)
     Sets the output files associated with the job.
public  voidsetPreScript(String path)
     It sets the prescript for the job.
public  voidsetPreScript(String path, String arguments)
     It sets the prescript for the job.
public  voidsetRemoteExecutable(String path)
     Sets the path to the executable on the remote grid site.
public  voidsetSiteHandle(String site)
    
public  voidsetStdErr(String fileName)
     Sets the file to which the stderr of the job needs to be written to at the remote grid site.
public  voidsetStdIn(String fileName)
     Sets the file to from which to pick up the stdin for the job.
public  voidsetStdOut(String fileName)
     Sets the file to which the stdout of the job needs to be written to at the remote grid site.
public  voidsetTXName(String name)
     Sets the transformation name of the underlying transformation.
public  voidsetTXNamespace(String ns)
     Sets the transformation namespace to be associated with the job.
public  voidsetTXVersion(String vs)
     Sets the version of the underlying transformation.
public  voidsetTransformation(String ns, String name, String vs)
     Sets the various attributes of underlying transformation.
public  voidsetUniverse(String universe)
     Set the universe associated with the job.
public  voidsetVDSSuperNode(String name)
     Setter method to the name of the compute job of VDS supernode containing this job.
public  StringtoDOT()
     Returns the DOT description of the object.
public  voidtoDOT(Writer stream, String indent)
     Returns the DOT description of the object.
public  StringtoString()
     Returns a textual description of the object.
public  booleantypeInRange(int type)
     Returns whether the job type value for the job is in range or not.
Parameters:
  type - the job type.
public  voidupdateProfiles(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  voidupdateProfiles(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  voidupdateProfiles(List profiles)
     Updates all the profile namespaces with the information specified in list of profile objects passed.

Field Detail
CLEANUP_JOB
final public static int CLEANUP_JOB(Code)
Denotes a cleanup job, that removes the files that from the remote working directories of the remote sites.



COMPUTE_JOB
final public static int COMPUTE_JOB(Code)
Denotes a compute job. Generally these are the jobs that are specified in the DAX.



CREATE_DIR_JOB
final public static int CREATE_DIR_JOB(Code)
Denotes a job that creates directories at the remote pools.



INTER_POOL_JOB
final public static int INTER_POOL_JOB(Code)
Denotes a job that transfers the output of a compute node to the site where the child compute node is to be generated.



REPLICA_REG_JOB
final public static int REPLICA_REG_JOB(Code)
Denotes a job that registers in the replica mechanism the materialized files.



STAGED_COMPUTE_JOB
final public static int STAGED_COMPUTE_JOB(Code)
Denotes a job for which the executable has been staged as part of the workflow.



STAGE_IN_JOB
final public static int STAGE_IN_JOB(Code)
Denotea a job that is used to stage in the input files for a compute job.



STAGE_OUT_JOB
final public static int STAGE_OUT_JOB(Code)
Denotes a job that transfers the date generated by a compute job to the output pool specified by the user.



UNASSIGNED_JOB
final public static int UNASSIGNED_JOB(Code)
Denotes a job that does not fall into the other categories. It might denote an error condition or a faulty logic in the planner.



condorUniverse
public String condorUniverse(Code)
The universe in which the job has to be executed. Can be standard, vanilla or globus.



condorVariables
public Condor condorVariables(Code)
For Condor Namespace. This contains the extra Condor options which one may want to specify. These are copied straightaway to the Submit file.



dagmanVariables
public Dagman dagmanVariables(Code)
The DAGMAN namespace profile variable holding the dagman profiles. It holds the prescript and the postscripts for the jobs.



dvName
public String dvName(Code)
The name of the derivation in Chimera that generated the job.



dvNamespace
public String dvNamespace(Code)
The namespace to which the derivation is bound.



dvVersion
public String dvVersion(Code)
The version of the derivation.



envVariables
public ENV envVariables(Code)
To accomodate the environment variables which might needed to be set.



executable
public String executable(Code)
The path of the executable on the machine at which the job is executed.



executionPool
public String executionPool(Code)
The pool on which this job has been decided to be executed by the Interpool Engine.



globusRSL
public Globus globusRSL(Code)
The namespace object containing the globus rsl attributes which the user specifies in the dax, or the pool file or the properties file.



globusScheduler
public String globusScheduler(Code)
The globus Scheduler for the job.



hints
public Hints hints(Code)
To accomodate all the hints that maybe passed through the DAX.



inputFiles
public Set inputFiles(Code)
Contains the input files for the submit file. They are vector of PegasusFile Objects which store the transiency information of each logical file.
See Also:   org.griphyn.cPlanner.classes.PegasusFile



jobClass
public int jobClass(Code)
The type of the job. Pegasus tags the jobs according to the function of the job. The jobs are tagged according to the functionality they serve in the VDS super node. The job class can be unassigned compute job stage-in stage-out replica registration inter-pool transfer create-dir job staged-compute job



jobID
public String jobID(Code)
Identifies of which VDS Super Node is a job associated with. VDS Supernode is identified by the jobName of the compute node in the super node.



jobName
public String jobName(Code)
The name of the job.



level
public int level(Code)
Identifies the level of the job in the dax. The level is bottom up from the final child node.



logicalId
public String logicalId(Code)
The logical id of the job as referred to in the dax.



logicalName
public String logicalName(Code)
The logical name of the transformation which is executed as a part of this job. Note: The tc is looked up by namespace__logicalName_version.



namespace
public String namespace(Code)
The namespace to which the transformation is bound.



outputFiles
public Set outputFiles(Code)
Contains the output files for the submit file. They are vector of PegasusFile Objects which store the transiency information of each logical file.
See Also:   org.griphyn.cPlanner.classes.PegasusFile



stdErr
public String stdErr(Code)
File which contains standard error.



stdIn
public String stdIn(Code)
File which contains stdin (keyboard input).



stdOut
public String stdOut(Code)
File which contains stdout.



strargs
public String strargs(Code)
The arguements for the job. It is the contains the arguments for the job. This string is put in the arguments in Condor Submit File.



vdsNS
public VDS vdsNS(Code)
The VDS namespace variable.



version
public String version(Code)
The version of the transformation.




Constructor Detail
SubInfo
public SubInfo()(Code)
Intialises the member variables.



SubInfo
public SubInfo(SubInfo job)(Code)
Overloaded constructor. Does a shallow copy of the job object passed.
Parameters:
  job - the SubInfo object containing the job description.




Method Detail
addInputFile
public void addInputFile(PegasusFile file)(Code)
Adds an input file to the underlying collection of input files associated with the job.
Parameters:
  file - the PegasusFile containing the input file.



addOutputFile
public void addOutputFile(PegasusFile file)(Code)
Adds an output file to the underlying collection of output files associated with the job.
Parameters:
  file - the PegasusFile containing the output file.



clone
public Object clone()(Code)
Returns a new copy of the Object. clone of the object.



equals
public boolean equals(Object obj)(Code)
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. true if the primary key (jobName) match.else false.



getArguments
public String getArguments()(Code)
Returns the argument string with which the job has to be invoked. the argument string.



getCompleteDVName
public String getCompleteDVName()(Code)
Constructs the fully qualified name of the corresponding derivation used to generate this job in Chimera including the namespace and version. the complete derivation name.



getCompleteTCName
public String getCompleteTCName()(Code)
Constructs the fully qualified name of a transformation with which to query the TC, including the namespace and version. the complete tranformation name.



getDOTColor
protected String getDOTColor()(Code)
Returns the color with which DOT should color the node representing the job. the color.



getDVName
public String getDVName()(Code)
Returns the name of the underlying derivation. name



getDVNamespace
public String getDVNamespace()(Code)
Returns the namespace of the underlying derivation. namespace



getDVVersion
public String getDVVersion()(Code)
Returns the version of the underlying derivation. version



getID
public String getID()(Code)
Returns the ID associated with the job. Unfortunately currently it is the job name. the ID of the job.



getInputFiles
public Set getInputFiles()(Code)
Returns the set of input files associated with the job. Set of PegasusFile objects containing the input files.



getJobManager
public String getJobManager()(Code)
Returnss the remote jobmanager on which the job has to run. the jobmanager url.
See Also:   SubInfo.setJobManager()



getJobType
public int getJobType()(Code)
Returns the type of the job. Returns the value matching the jobClass. int value of job class.



getJobTypeDescription
public String getJobTypeDescription()(Code)
Gets the textual description of the type associated with the job. the textual description of the type associated with the job.



getJobTypeDescription
public String getJobTypeDescription(int type)(Code)
Gets the textual description of the type that can be associated with a job.
Parameters:
  type - the type of the job. the textual description of the type associated with the job.



getLevel
public int getLevel()(Code)
Returns the level associated with the job. int designating the level



getLogicalID
public String getLogicalID()(Code)
Returns the logical id of the job. String



getName
public String getName()(Code)
Returns the name of the job. String



getOutputFiles
public Set getOutputFiles()(Code)
Returns the set of output files associated with the job. Set of PegasusFile objects containing the output files.



getPreScriptArguments
public String getPreScriptArguments()(Code)
Returns the arguments to the prescript for the job if set. the argumetns to the prescript script that has to be run as aprescript, else null if no prescript has been set.



getPreScriptPath
public String getPreScriptPath()(Code)
Returns the path to the prescript for the job if set. the path to the script that has to be run as a prescript, elsenull if no prescript has been set.



getRemoteExecutable
public String getRemoteExecutable()(Code)
Returns the path of the underlying executable on the remote grid site. the path to the executable if set.



getSiteHandle
public String getSiteHandle()(Code)
Returns the handle of the site where the job is scheduled. site handle.



getStagedExecutableBaseName
public String getStagedExecutableBaseName()(Code)
Returns the basename for the staged executable corresponding to the job. the staged executable basename



getStagedExecutableBaseName
public static String getStagedExecutableBaseName(String txNamespace, String txName, String txVersion)(Code)
Returns the basename for the staged executable corresponding to the job.
Parameters:
  txNamespace - is the namespace in which the TR resides, may be null.
Parameters:
  txName - is the base name of the transformation, must not be null.
Parameters:
  txVersion - is the version of the TR, may be null the staged executable basename



getStdErr
public String getStdErr()(Code)
Returns the file to which the stderr of the job is written to. the basename of the file.



getStdIn
public String getStdIn()(Code)
Returns the file from which the stdin is picked up. the basename of the file.



getStdOut
public String getStdOut()(Code)
Returns the file to which the stdout of the job is written to. the basename of the file.



getTXName
public String getTXName()(Code)
Returns the name of the underlying transformation. name



getTXNamespace
public String getTXNamespace()(Code)
Returns the namespace of the underlying transformation. namespace



getTXVersion
public String getTXVersion()(Code)
Returns the version of the underlying transformation. version



getUniverse
public String getUniverse()(Code)
Returns the universe associated with the job. the universe associate with job .



getVDSSuperNode
public String getVDSSuperNode()(Code)
Returns the name of the compute job of VDS supernode containing this job. String



isMPIJob
public boolean isMPIJob()(Code)
Returns a boolean value denoting whether the job is MPI or not. If no job type is specified in the globus rsl for the job, the job is assumed to be non mpi. boolean true if jobtype=mpi set in the globus rsl.false in all other cases.



mergeProfiles
public void mergeProfiles(SubInfo job)(Code)
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. Some profiles maybe overriden, others maybe summed up etc.
Parameters:
  job - the SubInfo object containing the job descriptionfor the job whose profiles have to be merged into this job.



resetProfiles
public void resetProfiles()(Code)
Resets all the profiles associated with the job.



runInWorkDirectory
public boolean runInWorkDirectory()(Code)
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. That would be the case if the job has been scheduled to site "local" and the class of the job coressponds to the auxillary jobs that have been created by Pegasus. boolean true to indicate job can run in work directory,false job cant be run.



setArguments
public void setArguments(String arguments)(Code)
Sets the argument string with which the job has to be invoked.
Parameters:
  arguments - the argument string.



setDVName
public void setDVName(String name)(Code)
Sets the derivation name of the underlying derivation.
Parameters:
  name - the logical name of the derivation.



setDVNamespace
public void setDVNamespace(String ns)(Code)
Sets the derivation namespace to be associated with the job.
Parameters:
  ns - the namespace.



setDVVersion
public void setDVVersion(String vs)(Code)
Sets the version of the underlying derivation.
Parameters:
  vs - the version.



setDerivation
public void setDerivation(String ns, String name, String vs)(Code)
Sets the various attributes of underlying derivation.
Parameters:
  ns - the namespace of the derivation.
Parameters:
  name - the logical name of the derivation.
Parameters:
  vs - the version of the derivation.



setInputFiles
public void setInputFiles(Set ipFiles)(Code)
Sets the input files associated with the job.
Parameters:
  ipFiles - Set of PegasusFile objects containing the input files.



setJobManager
public void setJobManager(String jobmanager)(Code)
Sets the remote jobmanager on which the job has to run.
Parameters:
  jobmanager - the jobmanager url.
See Also:   SubInfo.getJobManager()



setJobType
public void setJobType(int type)(Code)
Sets the type of the job.
Parameters:
  type - the type of the job.
exception:
  IllegalArgumentException - if the job type is outside its legalrange.
See Also:   SubInfo.UNASSIGNED_JOB
See Also:   SubInfo.COMPUTE_JOB
See Also:   SubInfo.STAGE_IN_JOB
See Also:   SubInfo.STAGE_OUT_JOB
See Also:   SubInfo.REPLICA_REG_JOB
See Also:   SubInfo.INTER_POOL_JOB
See Also:   SubInfo.CREATE_DIR_JOB
See Also:   SubInfo.STAGED_COMPUTE_JOB
See Also:   SubInfo.CLEANUP_JOB



setLevel
public void setLevel(int value)(Code)
Sets the level for the job.
Parameters:
  value - the level



setLogicalID
public void setLogicalID(String id)(Code)
Setter method to set the logical id of the job.
Parameters:
  id - the logical id of the job.



setName
public void setName(String name)(Code)
Setter method to set the name of the job.
Parameters:
  name - the name of the job.



setOutputFiles
public void setOutputFiles(Set opFiles)(Code)
Sets the output files associated with the job.
Parameters:
  opFiles - Set of PegasusFile objects containing theoutput files.



setPreScript
public void setPreScript(String path)(Code)
It sets the prescript for the job. The argument string is assumed to be empty.
Parameters:
  path - the path to the script that has to be run as a prescript.



setPreScript
public void setPreScript(String path, String arguments)(Code)
It sets the prescript for the job.
Parameters:
  path - the path to the script that has to be run as a prescript.
Parameters:
  arguments - the arguments to the prescript,



setRemoteExecutable
public void setRemoteExecutable(String path)(Code)
Sets the path to the executable on the remote grid site. This executable is invoked whenever a job is run on the remote grid site.
Parameters:
  path - the path to the underlying transformation on the remote gridsite.
See Also:   SubInfo.getSiteHandle()



setSiteHandle
public void setSiteHandle(String site)(Code)
Sets the site handle of the site, where teh job is to be executed
Parameters:
  site - the site handle.



setStdErr
public void setStdErr(String fileName)(Code)
Sets the file to which the stderr of the job needs to be written to at the remote grid site. Should be just the basename. The file appears in the remote working directory for that job.
Parameters:
  fileName - the basename of the file.



setStdIn
public void setStdIn(String fileName)(Code)
Sets the file to from which to pick up the stdin for the job. The file is tracked via Replica Catalog, and is staged to the remote grid site.
Parameters:
  fileName - the basename of the file.



setStdOut
public void setStdOut(String fileName)(Code)
Sets the file to which the stdout of the job needs to be written to at the remote grid site. Should be just the basename. The file appears in the remote working directory for that job.
Parameters:
  fileName - the basename of the file.



setTXName
public void setTXName(String name)(Code)
Sets the transformation name of the underlying transformation.
Parameters:
  name - the logical name of the transformation.



setTXNamespace
public void setTXNamespace(String ns)(Code)
Sets the transformation namespace to be associated with the job.
Parameters:
  ns - the namespace.



setTXVersion
public void setTXVersion(String vs)(Code)
Sets the version of the underlying transformation.
Parameters:
  vs - the version.



setTransformation
public void setTransformation(String ns, String name, String vs)(Code)
Sets the various attributes of underlying transformation.
Parameters:
  ns - the namespace of the transformation.
Parameters:
  name - the logical name of the transformation.
Parameters:
  vs - the version of the transformation.



setUniverse
public void setUniverse(String universe)(Code)
Set the universe associated with the job.
Parameters:
  universe - the universe to be associated.



setVDSSuperNode
public void setVDSSuperNode(String name)(Code)
Setter method to the name of the compute job of VDS supernode containing this job.
Parameters:
  name - the name of the job.



toDOT
public String toDOT() throws IOException(Code)
Returns the DOT description of the object. This is used for visualizing the workflow. String containing the Partition object in XML.
exception:
  IOException - if something fishy happens to the stream.



toDOT
public void toDOT(Writer stream, String indent) throws IOException(Code)
Returns the DOT description of the object. This is used for visualizing the workflow.
Parameters:
  stream - is a stream opened and ready for writing. This can alsobe a StringWriter for efficient output.
Parameters:
  indent - is a String of spaces used for prettyprinting. The initial amount of spaces should be an emptystring. The parameter is used internally for the recursivetraversal.
exception:
  IOException - if something fishy happens to the stream.



toString
public String toString()(Code)
Returns a textual description of the object. textual description of the job.



typeInRange
public boolean typeInRange(int type)(Code)
Returns whether the job type value for the job is in range or not.
Parameters:
  type - the job type. true if the value is in range.false if the value is not in range.



updateProfiles
public void updateProfiles(TransformationCatalogEntry entry)(Code)
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. The calling method should ensure this.
Parameters:
  entry - the TCEntry object corresponding to theentry in the Transformation Catalog for the job.



updateProfiles
public void updateProfiles(PegasusProperties properties)(Code)
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. The calling method should ensure this.
Parameters:
  properties - the PegasusProperties object containingthe user properties.



updateProfiles
public void updateProfiles(List profiles)(Code)
Updates all the profile namespaces with the information specified in list of profile objects passed. Pool catalog returns profile information as a list of Profile objects that need to be propogated to the job. It ends up updating already existing information, and adds supplemental new information if present in the properties file.
Parameters:
  profiles - the list of Profile objects that need to beincorporated in the jobs profile namespaces.



Fields inherited from org.griphyn.cPlanner.classes.Data
public String mLogMsg(Code)(Java Doc)
public LogManager mLogger(Code)(Java Doc)

Methods inherited from org.griphyn.cPlanner.classes.Data
public String setToString(Set s, String delim)(Code)(Java Doc)
abstract public String toString()(Code)(Java Doc)
public String vectorToString(String heading, Vector vector)(Code)(Java Doc)

Methods inherited from java.lang.Object
native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.