edu.isi.pegasus.planner.refiner.createdir
Modifier and Type | Field and Description |
---|---|
static String |
CREATE_DIR_PREFIX
Constant prefix for the names of the create directory nodes.
|
static String |
CREATE_DIR_SUFFIX
Constant suffix for the names of the create directory nodes.
|
protected Implementation |
mImpl
The implementation instance that is used to create a create dir job.
|
protected String |
mJobPrefix
The job prefix that needs to be applied to the job file basenames.
|
protected LogManager |
mLogger
The handle to the logging object, that is used to log the messages.
|
protected SiteStore |
mSiteStore
The Site Store handle.
|
protected boolean |
mUseMkdir
Whether we want to use dirmanager or mkdir directly.
|
Constructor and Description |
---|
AbstractStrategy() |
Modifier and Type | Method and Description |
---|---|
String |
getCreateDirJobName(ADag dag,
String pool)
It returns the name of the create directory job, that is to be assigned.
|
protected Set |
getCreateDirSites(ADag dag)
Retrieves the sites for which the create dir jobs need to be created.
|
void |
initialize(PegasusBag bag,
Implementation impl)
Intializes the class.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addCreateDirectoryNodes
public static final String CREATE_DIR_SUFFIX
public static final String CREATE_DIR_PREFIX
protected LogManager mLogger
protected String mJobPrefix
protected boolean mUseMkdir
protected Implementation mImpl
protected SiteStore mSiteStore
public void initialize(PegasusBag bag, Implementation impl)
initialize
in interface Strategy
bag
- bag of initialization objectsimpl
- the implementation instance that creates create dir jobpublic String getCreateDirJobName(ADag dag, String pool)
dag
- the workflow to which the create dir jobs are being added.pool
- the execution pool for which the create directory job
is responsible.