edu.isi.pegasus.planner.refiner.createdir
public class Minimal extends AbstractStrategy
CREATE_DIR_PREFIX, CREATE_DIR_SUFFIX, mImpl, mJobPrefix, mLogger, mSiteStore, mUseMkdir
Constructor and Description |
---|
Minimal() |
Modifier and Type | Method and Description |
---|---|
ADag |
addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes.
|
Graph |
addCreateDirectoryNodes(Graph workflow,
ADag dag,
Set<String> sites)
Adds create dir nodes to the workflow.
|
boolean |
addDependency(Job job) |
private String |
getAssociatedCreateDirSite(Job job)
Returns the associated site that job is dependant on.
|
void |
initialize(PegasusBag bag,
Implementation impl)
Intializes the class.
|
getCreateDirJobName, getCreateDirSites
public void initialize(PegasusBag bag, Implementation impl)
initialize
in interface Strategy
initialize
in class AbstractStrategy
bag
- bag of initialization objectsimpl
- the implementation instance that creates create dir jobpublic ADag addCreateDirectoryNodes(ADag dag)
dag
- the workflow to which the nodes have to be added.public Graph addCreateDirectoryNodes(Graph workflow, ADag dag, Set<String> sites)
workflow
- the workflowdag
- the original dag structuresites
- the staging sites the workflow refers to.private String getAssociatedCreateDirSite(Job job)
job
- the job for which we need the associated create dir site.public boolean addDependency(Job job)