Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CREATE_DIR_PREFIX
Constant prefix for the names of the create directory nodes.
|
static java.lang.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 java.lang.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 |
---|---|
java.lang.String |
getCreateDirJobName(ADag dag,
java.lang.String pool)
It returns the name of the create directory job, that is to be assigned.
|
static java.util.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 java.lang.String CREATE_DIR_SUFFIX
public static final java.lang.String CREATE_DIR_PREFIX
protected LogManager mLogger
protected java.lang.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 java.lang.String getCreateDirJobName(ADag dag, java.lang.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.public static java.util.Set getCreateDirSites(ADag dag)