Java Doc for ADag.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.ADag

ADag
public class ADag extends Data (Code)
This class object contains the info about a Dag. DagInfo object contains the information to create the .dax file. vJobSubInfos is a Vector containing SubInfo objects of jobs making the Dag. Each subinfo object contains information needed to generate a submit file for that job.
author:
   Karan Vahi
author:
   Gaurang Mehta
version:
   $Revision: 351 $
See Also:   DagInfo
See Also:   SubInfo


Field Summary
public  DagInfodagInfo
     The DagInfo object which contains the information got from parsing the dax file.
public  VectorvJobSubInfos
     Vector of SubInfo objects.

Constructor Summary
public  ADag()
     Initialises the class member variables.
public  ADag(DagInfo dg, Vector vSubs)
     Overloaded constructor.

Method Summary
public  voidadd(SubInfo job)
     This adds a new job to the ADAG object.
public  voidaddNewRelation(String parent, String child)
     Adds a new PCRelation pair to the Vector of PCRelation pairs.
public  voidaddNewRelation(String parent, String child, boolean isDeleted)
     Adds a new PCRelation pair to the Vector of PCRelation pairs.
public  voidclearJobs()
     Removes all the jobs from the workflow, and all the edges between the workflows.
public  Objectclone()
     Returns a new copy of the Object.
public  StringgetBaseSubmitDirectory()
     Returns the root of submit directory hierarchy for the workflow.
public  VectorgetChildren(String node)
     Get all the children of a particular node.
Parameters:
  node - the name of the node whose children we want to find.
public  SetgetExecutionSites()
     It returns the a unique list of the execution sites that the Planner has mapped the dax to so far in it's stage of planning .
public  StringgetLabel()
     Returns the label of the workflow, that was specified in the DAX.
public  VectorgetLeafNodes()
     Returns all the leaf nodes of the dag.
public  StringgetMTime()
     Returns the last modified time for the file containing the workflow description.
public  intgetNoOfJobs()
     Returns the number of jobs in the dag on the basis of number of elements in the dagJobs Vector.
public  VectorgetParents(String node)
     Gets all the parents of a particular node
Parameters:
  node - the name of the job whose parents are to be found.
public  StringgetRequestID()
     Returns the request id.
public  VectorgetRootNodes()
     It determines the root Nodes for the ADag looking at the relation pairs of the adag.
public  SubInfogetSubInfo(String job)
     This returns a SubInfo object corresponding to the job by looking through all the subInfos.
Parameters:
  job - jobName of the job for which we need the subInfo object.
public  WorkflowMetricsgetWorkflowMetrics()
     Returns the metrics about the workflow.
public  booleanisEmpty()
     Returns whether the workflow is empty or not.
public  IteratorjobIterator()
     Returns an iterator for traversing through the jobs in the workflow.
public  booleanremove(SubInfo job)
     Removes a particular job from the workflow.
public  voidsetBaseSubmitDirectory(String dir)
     Sets the submit directory for the workflow.
public  voidsetRequestID(String id)
     Sets the request id.
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 the String description of the dag associated with this object.
public  voidwriteDOTHeader(Writer stream, String indent)
     Writes out the static DOT Header.
Parameters:
  stream - is a stream opened and ready for writing.

Field Detail
dagInfo
public DagInfo dagInfo(Code)
The DagInfo object which contains the information got from parsing the dax file.



vJobSubInfos
public Vector vJobSubInfos(Code)
Vector of SubInfo objects. Each SubInfo object contains information corresponding to the submit file for one job.




Constructor Detail
ADag
public ADag()(Code)
Initialises the class member variables.



ADag
public ADag(DagInfo dg, Vector vSubs)(Code)
Overloaded constructor.
Parameters:
  dg - the DagInfo
Parameters:
  vSubs - the jobs in the workflow.




Method Detail
add
public void add(SubInfo job)(Code)
This adds a new job to the ADAG object. It ends up adding both the job name and the job description to the internal structure.
Parameters:
  job - the new job that is to be added to the ADag.



addNewRelation
public void addNewRelation(String parent, String child)(Code)
Adds a new PCRelation pair to the Vector of PCRelation pairs. For the new relation the isDeleted parameter is set to false.
Parameters:
  parent - The parent in the relation pair
Parameters:
  child - The child in the relation pair
See Also:   org.griphyn.cPlanner.classes.PCRelation



addNewRelation
public void addNewRelation(String parent, String child, boolean isDeleted)(Code)
Adds a new PCRelation pair to the Vector of PCRelation pairs.
Parameters:
  parent - The parent in the relation pair
Parameters:
  child - The child in the relation pair
Parameters:
  isDeleted - Whether the relation has been deleted due to the reductionalgorithm or not.
See Also:   org.griphyn.cPlanner.classes.PCRelation



clearJobs
public void clearJobs()(Code)
Removes all the jobs from the workflow, and all the edges between the workflows. The only thing that remains is the meta data about the workflow.



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



getBaseSubmitDirectory
public String getBaseSubmitDirectory()(Code)
Returns the root of submit directory hierarchy for the workflow. the directory.



getChildren
public Vector getChildren(String node)(Code)
Get all the children of a particular node.
Parameters:
  node - the name of the node whose children we want to find. Vector containing thechildren of the node



getExecutionSites
public Set getExecutionSites()(Code)
It returns the a unique list of the execution sites that the Planner has mapped the dax to so far in it's stage of planning . This is a subset of the pools specified by the user at runtime. a TreeSet containing a list of siteID's of the sites where thedag has to be run.



getLabel
public String getLabel()(Code)
Returns the label of the workflow, that was specified in the DAX. the label of the workflow.



getLeafNodes
public Vector getLeafNodes()(Code)
Returns all the leaf nodes of the dag. The way the structure of Dag is specified, in terms of the parent child relationship pairs, the determination of the leaf nodes can be computationally intensive. The complexity is of order n^2 Vector of String corresponding to the job names ofthe leaf nodes.
See Also:   org.griphyn.cPlanner.classes.PCRelation
See Also:   org.griphyn.cPlanner.classes.DagInfo.relations



getMTime
public String getMTime()(Code)
Returns the last modified time for the file containing the workflow description. the MTime



getNoOfJobs
public int getNoOfJobs()(Code)
Returns the number of jobs in the dag on the basis of number of elements in the dagJobs Vector. the number of jobs.



getParents
public Vector getParents(String node)(Code)
Gets all the parents of a particular node
Parameters:
  node - the name of the job whose parents are to be found. Vector corresponding to the parents of the node



getRequestID
public String getRequestID()(Code)
Returns the request id. the request id.



getRootNodes
public Vector getRootNodes()(Code)
It determines the root Nodes for the ADag looking at the relation pairs of the adag. The way the structure of Dag is specified in terms of the parent child relationship pairs, the determination of the leaf nodes can be computationally intensive. The complexity if of order n^2. the root jobs of the Adag
See Also:   org.griphyn.cPlanner.classes.PCRelation
See Also:   org.griphyn.cPlanner.classes.DagInfo.relations



getSubInfo
public SubInfo getSubInfo(String job)(Code)
This returns a SubInfo object corresponding to the job by looking through all the subInfos.
Parameters:
  job - jobName of the job for which we need the subInfo object. the SubInfo objects corresponding to the job



getWorkflowMetrics
public WorkflowMetrics getWorkflowMetrics()(Code)
Returns the metrics about the workflow. the WorkflowMetrics



isEmpty
public boolean isEmpty()(Code)
Returns whether the workflow is empty or not. boolean



jobIterator
public Iterator jobIterator()(Code)
Returns an iterator for traversing through the jobs in the workflow. Iterator



remove
public boolean remove(SubInfo job)(Code)
Removes a particular job from the workflow. It however does not delete the relations the edges that refer to the job.
Parameters:
  job - the SubInfo object containing the job description. boolean indicating whether the removal was successful or not.



setBaseSubmitDirectory
public void setBaseSubmitDirectory(String dir)(Code)
Sets the submit directory for the workflow.
Parameters:
  dir - the submit directory.



setRequestID
public void setRequestID(String id)(Code)
Sets the request id.
Parameters:
  id - the request id.



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 the String description of the dag associated with this object. textual description.



writeDOTHeader
public void writeDOTHeader(Writer stream, String indent) throws IOException(Code)
Writes out the static DOT Header.
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.



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.