Package | Description |
---|---|
edu.isi.pegasus.planner.cluster | |
edu.isi.pegasus.planner.refiner |
Modifier and Type | Method and Description |
---|---|
void |
Horizontal.determineClusters(Partition partition)
Determine the clusters for a partition.
|
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.
|
ADag |
Horizontal.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Abstract.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Clusterer.getClusteredDAG()
Returns the clustered workflow.
|
void |
Horizontal.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
void |
Abstract.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
void |
Clusterer.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
List |
Vertical.order(Partition p)
Returns the nodes in the partition as a List in the topologically sorted
order.
|
abstract List<String> |
Abstract.order(Partition p)
Returns the nodes in the partition as a List in a particular order.
|
void |
Horizontal.parents(String partitionID,
List parents)
Am empty implementation of the callout, as state is maintained
internally to determine the relations between the jobs.
|
void |
Abstract.parents(String partitionID,
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(String partitionID,
List parents)
Associates the relations between the partitions with the corresponding
relations between the clustered jobs that are created for each Partition.
|
Modifier and Type | Method and Description |
---|---|
ADag |
NodeCollapser.cluster(ADag dag)
Clusters the jobs in the workflow.
|
ADag |
NodeCollapser.cluster(ADag dag,
String type)
Clusters the jobs in the workflow.
|