|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Callback | |
|---|---|
| edu.isi.pegasus.planner.partitioner | |
| Uses of Callback in edu.isi.pegasus.planner.partitioner |
|---|
| Classes in edu.isi.pegasus.planner.partitioner that implement Callback | |
|---|---|
class |
ClustererCallback
A Callback implementation that passes the partitions detected during the partitioning of the worflow to a Clusterer for clustering. |
class |
WriterCallback
This callback writes out a DAX file for each of the partitions,
and also writes out a PDAX file that captures the relations
between the partitions. |
| Methods in edu.isi.pegasus.planner.partitioner with parameters of type Callback | |
|---|---|
protected void |
BFS.constructLevelRelations(Callback c,
int parent,
int child)
Calls out to the callback with appropriate relations between the partitions constructed for the levels. |
protected void |
Horizontal.constructLevelRelations(Callback c,
int parent,
int child)
Calls out to the callback with appropriate relations between the partitions constructed for the levels. |
protected void |
BFS.constructPartitions(Callback c,
List nodes,
int level)
Given a list of jobs, constructs (one or more) partitions out of it. |
protected void |
Horizontal.constructPartitions(Callback c,
List nodes,
int level)
Given a list of jobs, constructs (one or more) partitions out of it. |
protected void |
Horizontal.constructPartitions(Callback c,
List nodes,
int level,
String name)
Given a list of jobs, constructs (one or more) partitions out of it. |
void |
One2One.determinePartitions(Callback c)
This ends up writing out a partition for each job in the dax. |
void |
Label.determinePartitions(Callback c)
Partitions the graph passed in the constructor, on the basis of the labels associated with the nodes in the graph. |
void |
BFS.determinePartitions(Callback c)
Does a constrained breadth first search to identify the partitions, and calls out to write out the partition graph. |
void |
Whole.determinePartitions(Callback c)
This ends up writing out a partition for each job in the dax. |
abstract void |
Partitioner.determinePartitions(Callback c)
The main function that ends up traversing the graph structure corrsponding to the dax and creates the smaller dax files(one dax file per partition) and the .pdax file that illustrates the partition graph. |
protected void |
BFS.done(Callback c)
Indicates that we are done with the partitioning. |
protected void |
Horizontal.done(Callback c)
Indicates that we are done with the traversal of the graph. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||