public interface Clusterer
Modifier and Type | Field and Description |
---|---|
static String |
VERSION
The version number associated with this API of Code Generator.
|
Modifier and Type | Method and Description |
---|---|
String |
description()
Returns a textual description of the transfer implementation.
|
void |
determineClusters(Partition partition)
Determine the clusters for a partition.
|
ADag |
getClusteredDAG()
Returns the clustered workflow.
|
void |
initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
void |
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.
|
static final String VERSION
void initialize(ADag dag, PegasusBag bag) throws ClustererException
dag
- the workflow that is being clustered.bag
- the bag of objects that is useful for initialization.ClustererException
- in case of error.void determineClusters(Partition partition) throws ClustererException
partition
- the partition for which the clusters need to be
determined.ClustererException
- in case of error.void parents(String partitionID, List parents) throws ClustererException
partitionID
- the id of a partition.parents
- the list of String
objects that contain
the id's of the parents of the partition.ClustererException
- in case of error.ADag getClusteredDAG() throws ClustererException
ADag
object corresponding to the clustered workflow.ClustererException
- in case of error.String description()
Copyright © 2011 The University of Southern California. All Rights Reserved.