| Method Summary |
|
| protected void | addJob(SubInfo job)
Adds jobs to the internal map of jobs that is maintained by the clusterer. |
| protected void | associate(Partition p, SubInfo job)
Maps the partition to the corresponding clustered job. |
| protected SubInfo | clusteredJob(Partition p)
Returns the job corresponding to a partition.
Parameters:
p - the partition for which the clustered job is reqd. |
| protected SubInfo | clusteredJob(String id)
Returns the job corresponding to a partition.
Parameters:
id - the partition id. |
| protected String | constructClusteredJobID(Partition partition)
Returns the ID for the clustered job corresponding to a partition.
Parameters:
partition - the partition. |
| public void | determineClusters(Partition partition)
It creates a single clustered job for the partition. |
| abstract public void | determineInputOutputFiles(AggregatedJob job)
Determine the input and output files of the job on the basis of the
order of the constituent jobs in the AggregatedJob. |
| public ADag | getClusteredDAG()
Returns the clustered workflow. |
| protected SubInfo | getJob(String id)
Returns the job object corresponding to the id of the job. |
| public void | initialize(ADag dag, PegasusBag bag)
|
| abstract public List | order(Partition p)
Returns the nodes in the partition as a List in a particular order.
The iterator of the list returns the nodes in the order determined by
the clusterer.
Parameters:
p - the partition whose nodes have to be ordered. |
| public 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. |
