void |
Abstract.determineClusters(Partition partition) |
It creates a single clustered job for the partition.
|
void |
Clusterer.determineClusters(Partition partition) |
Determine the clusters for a partition.
|
void |
Horizontal.determineClusters(Partition partition) |
Determine the clusters for a partition.
|
ADag |
Abstract.getClusteredDAG() |
Returns the clustered workflow.
|
ADag |
Clusterer.getClusteredDAG() |
Returns the clustered workflow.
|
ADag |
Horizontal.getClusteredDAG() |
Returns the clustered workflow.
|
void |
Abstract.initialize(ADag dag,
PegasusBag bag) |
Initializes the Clusterer impelementation
|
void |
Clusterer.initialize(ADag dag,
PegasusBag bag) |
Initializes the Clusterer impelementation
|
void |
Horizontal.initialize(ADag dag,
PegasusBag bag) |
Initializes the Clusterer impelementation
|
abstract java.util.List<java.lang.String> |
Abstract.order(Partition p) |
Returns the nodes in the partition as a List in a particular order.
|
java.util.List |
Vertical.order(Partition p) |
Returns the nodes in the partition as a List in the topologically sorted
order.
|
void |
Abstract.parents(java.lang.String partitionID,
java.util.List parents) |
Associates the relations between the partitions with the corresponding
relations between the clustered jobs that are created for each Partition.
|
void |
Clusterer.parents(java.lang.String partitionID,
java.util.List parents) |
Associates the relations between the partitions with the corresponding
relations between the clustered jobs that are created for each Partition.
|
void |
Horizontal.parents(java.lang.String partitionID,
java.util.List parents) |
Am empty implementation of the callout, as state is maintained
internally to determine the relations between the jobs.
|