public class NodeCollapser extends Engine
Modifier and Type | Field and Description |
---|---|
private PegasusBag |
mBag
The bag of initialization objects.
|
private String |
mDirectory
The directory, where the stdin file of the fat jobs are created.
|
private Map |
mGraph
The internal map that contains the adjacency list representation of the
Graph referred to by the workflow.
|
protected LogManager |
mLogger
The handle to the logger object.
|
mLogMsg, mOutputPool, mPoolFile, mPOptions, mProps, mRLIUrl, mSiteStore, mTCFile, mTCHandle, mTCMode, REGISTRATION_UNIVERSE, TRANSFER_UNIVERSE
Constructor and Description |
---|
NodeCollapser(PegasusBag bag)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
ADag |
cluster(ADag dag)
Clusters the jobs in the workflow.
|
ADag |
cluster(ADag dag,
String type)
Clusters the jobs in the workflow.
|
protected Map |
edgeList2Graph(ADag dag,
Map nameIDMap)
Returns an adjacency list representation of the graph referred to by
the list of edges.
|
protected Map |
edgeList2Graph(Collection<PCRelation> relations,
Map nameIDMap)
Deprecated.
as part of PM-747
|
void |
setDirectory(String directory)
Sets the directory where the stdin files are to be generated.
|
addVector, appendArrayList, complainForHeadNodeURLPrefix, complainForHeadNodeURLPrefix, loadProperties, printVector, stringInList, stringInPegVector, stringInVector, vectorToString
protected LogManager mLogger
private String mDirectory
private Map mGraph
private PegasusBag mBag
public NodeCollapser(PegasusBag bag)
bag
- the bag of initialization objects.public void setDirectory(String directory)
directory
- the path to the directory to which it needs to be set.public ADag cluster(ADag dag) throws ClustererException
dag
- the scheduled dag that has to be clustered.ClustererException
- in case of error while clusteringpublic ADag cluster(ADag dag, String type) throws ClustererException
dag
- the scheduled dag that has to be clustered.type
- the type of clustering to do.ClustererException
- in case of error while clusteringprotected Map edgeList2Graph(ADag dag, Map nameIDMap)
dag
- the workflownameIDMap
- map with the key as the jobname and value as the
logical idprotected Map edgeList2Graph(Collection<PCRelation> relations, Map nameIDMap)
relations
- collection of PCRelation
objects that does
the conversion.nameIDMap
- map with the key as the jobname and value as the
logical id