Package | Description |
---|---|
edu.isi.pegasus.planner.cluster | |
edu.isi.pegasus.planner.refiner |
Modifier and Type | Method and Description |
---|---|
void |
Clusterer.determineClusters(Partition partition)
Determine the clusters for a partition.
|
void |
Abstract.determineClusters(Partition partition)
It creates a single clustered job for the partition.
|
void |
Horizontal.determineClusters(Partition partition)
Determine the clusters for a partition.
|
ADag |
Clusterer.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Abstract.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Horizontal.getClusteredDAG()
Returns the clustered workflow.
|
void |
Clusterer.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
void |
Abstract.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 |
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 |
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
ADag |
NodeCollapser.cluster(ADag dag)
Clusters the jobs in the workflow.
|
ADag |
NodeCollapser.cluster(ADag dag,
java.lang.String type)
Clusters the jobs in the workflow.
|