| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.NodeCollapser
| NodeCollapser | | public class NodeCollapser extends Engine (Code) | | This collapses the nodes of the same logical name scheduled on the same
pool into fewer fat nodes. The idea behind this is to collapse jobs that
take a few seconds to run into a larger job, and hence reducing time because
of lesser delays due to lesser number of Condor Globus interactions.
Note that the merging of the edges for the jobs being collapsed at present, is
not the best implementation. Once the graph structure is correct , it would
be modified.
author:
Karan Vahi vahi@isi.edu
author:
Mei-Hui Su mei@isi.edu
version:
$Revision: 450 $ |
| Method Summary | |
| public ADag | cluster(ADag dag)
Clusters the jobs in the workflow. | | public ADag | cluster(ADag dag, String type)
Clusters the jobs in the workflow. | | protected Map | edgeList2Graph(Vector relations, Map nameIDMap)
Returns an adjacency list representation of the graph referred to by
the list of edges. | | public void | setDirectory(String directory)
Sets the directory where the stdin files are to be generated. |
| NodeCollapser | | public NodeCollapser(PegasusBag bag)(Code) | | The overloaded constructor.
Parameters:
bag - the bag of initialization objects. |
| cluster | | public ADag cluster(ADag dag) throws ClustererException(Code) | | Clusters the jobs in the workflow. It applies a series of clustering
actions on the graph, as specified by the user at runtime.
For each clustering action, the graph is first partitioned,
and then sent to the appropriate clustering module for clustering.
Parameters:
dag - the scheduled dag that has to be clustered. ADag containing the collapsed scheduled workflow.
throws:
ClustererException - in case of error while clustering |
| cluster | | public ADag cluster(ADag dag, String type) throws ClustererException(Code) | | Clusters the jobs in the workflow. The graph is first partitioned,
and then sent to the appropriate clustering module for clustering.
Parameters:
dag - the scheduled dag that has to be clustered.
Parameters:
type - the type of clustering to do. ADag containing the collapsed scheduled workflow.
throws:
ClustererException - in case of error while clustering |
| edgeList2Graph | | protected Map edgeList2Graph(Vector relations, Map nameIDMap)(Code) | | Returns an adjacency list representation of the graph referred to by
the list of edges. The map contains adjacency list with key as a child
and value as the list of parents.
Parameters:
relations - vector of PCRelation objects that doesthe conversion.
Parameters:
nameIDMap - map with the key as the jobname and value as thelogical id Map. |
| setDirectory | | public void setDirectory(String directory)(Code) | | Sets the directory where the stdin files are to be generated.
Parameters:
directory - the path to the directory to which it needs to be set. |
|
|