edu.isi.pegasus.planner.namespace
public class Dagman extends Namespace
Namespace.EmptyIterator
Modifier and Type | Field and Description |
---|---|
static String |
CATEGORY_KEY
The name of the key that determines the category to which the job
belongs to.
|
static String |
DEFAULT_POST_SCRIPT_ARGUMENTS_KEY_VALUE
The default value for the arguments passed to postscript
|
static String |
DEFAULT_PRE_SCRIPT_ARGUMENTS_KEY_VALUE
The default value for the arguments passed to prescript
|
static String |
DEFAULT_RETRY_VALUE
The default value for the JOB Retries
|
static String |
DIRECTORY_EXTERNAL_KEY
The name of the key that indicates the directory in which the
DAG has to be execute
|
static String |
JOB_KEY
The name of the key that indicates the path to the corresponding
submit file for the job.
|
static String |
MAX_KEYS_PREFIX
The prefix for the max keys
|
static String |
MAXIDLE_KEY
The key name for max idle setting for dagman
|
static String |
MAXJOBS_KEY
The key name for max jobs setting for dagman
|
static String |
MAXPOST_KEY
The key name for max post setting for dagman
|
static String |
MAXPRE_KEY
The key name for max pre setting for dagman
|
private String |
mJobName
The name of the job (jobname) to which the profiles for this namespace
belong.
|
protected String |
mNamespace
The name of the implementing namespace.
|
static String |
NAMESPACE_NAME
The name of the namespace that this class implements.
|
static String |
OUTPUT_KEY
The name of the key that determines the file on the submit host on
which postscript is to be invoked.
|
static String |
POST_SCRIPT_ARGUMENTS_KEY
The name of the key that determines the arguments that need to be passed
to the postscript.
|
static String |
POST_SCRIPT_KEY
The name of the key that determines what post script is to be invoked
when the job completes.
|
static String |
POST_SCRIPT_PATH_PREFIX
The key prefix that determines the path to a postscript
|
private static String |
POST_SCRIPT_REPLACEMENT_KEY
The key name for the post script that is put in the .dag file.
|
static String |
POST_SCRIPT_SCOPE_KEY
The key prefix that determines the path to a postscript
|
static String |
PRE_SCRIPT_ARGUMENTS_KEY
The name of the key that determines the arguments that need to be passed
to the postscript.
|
static String |
PRE_SCRIPT_KEY
The name of the key that determines what pre script is to be invoked
when the job is run.
|
private static String |
PRE_SCRIPT_REPLACEMENT_KEY
The key name for the pre script that is put in the .dag file.
|
static String |
PRIORITY_KEY
The name of the key that determines the priority a job is assigned.
|
static String |
RETRY_KEY
The name of the key that determines how many times DAGMAN should be
retrying the job.
|
static String |
SUBDAG_EXTERNAL_KEY
The name of the key that indicates the path to the external subdag
|
DEPRECATED_KEY, EMPTY_KEY, MALFORMED_KEY, mLogger, mProfileMap, NOT_PERMITTED_KEY, UNKNOWN_KEY, VALID_KEY, VERSION
Constructor and Description |
---|
Dagman()
The default constructor.
|
Dagman(Map mp)
The overloaded constructor.
|
Dagman(Map mp,
String name)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
protected StringBuffer |
append(StringBuffer sb,
String key,
String name,
String value) |
void |
assimilate(PegasusProperties properties,
Profiles.NAMESPACES namespace)
Assimilate the profiles in the namespace in a controlled manner.
|
static boolean |
categoryRelatedKey(String key)
Determines whether a key is category related or not.
|
int |
checkKey(String key,
String value)
This checks whether the key passed by the user is valid in the current
namespace or not.
|
void |
checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
checkKeyInNS(String key,
String value)
This checks the whether a key value pair specified is valid in the current
namespace or not by calling the checkKey function and then on the basis of
the values returned puts them into the associated map in the class.
|
Object |
clone()
Returns a copy of the current namespace object.
|
void |
construct(String key,
String value)
Constructs a new element of the format (key=value).
|
String |
getPOSTScriptPath(String type)
Returns the path to the postscript of a particular type
|
private boolean |
ignore(String key)
Helper method to decide whether a key has to be ignored or not.
|
void |
merge(Namespace profiles)
Merge the profiles in the namespace in a controlled manner.
|
String |
namespaceName()
Returns the name of the namespace associated with the profile implementations.
|
private String |
replacementKey(String key)
Returns the replacement key that needs to be printed in .dag file in
lieu of the key.
|
private String |
replacementValue(String key)
Returns the replacement value that needs to be printed in .dag file for
a key.
|
void |
setJobName(String name)
It sets the name of the job that is associated with the profiles contained
in this placeholder.
|
String |
toCondor()
Converts the contents of the map into the string that can be put in the
Condor file for printing.
|
String |
toString(String name)
Converts the contents of the map into the string that can be put in the
Condor file for printing.
|
checkKeyInNS, checkKeyInNS, checkKeyInNS, checkKeyInNS, containsKey, deprecatedKey, deprecatedTable, emptyKey, get, getProfileKeyIterator, isEmpty, isNamespaceValid, keySet, malformedKey, notPermitted, removeKey, toString, unknownKey
public static final String NAMESPACE_NAME
public static final String POST_SCRIPT_KEY
public static final String POST_SCRIPT_ARGUMENTS_KEY
public static final String POST_SCRIPT_PATH_PREFIX
public static final String POST_SCRIPT_SCOPE_KEY
public static final String DEFAULT_POST_SCRIPT_ARGUMENTS_KEY_VALUE
public static final String PRE_SCRIPT_KEY
public static final String PRE_SCRIPT_ARGUMENTS_KEY
public static final String OUTPUT_KEY
public static final String DEFAULT_PRE_SCRIPT_ARGUMENTS_KEY_VALUE
public static final String RETRY_KEY
public static final String DEFAULT_RETRY_VALUE
public static final String CATEGORY_KEY
public static final String PRIORITY_KEY
public static final String JOB_KEY
public static final String SUBDAG_EXTERNAL_KEY
public static final String DIRECTORY_EXTERNAL_KEY
private static final String POST_SCRIPT_REPLACEMENT_KEY
private static final String PRE_SCRIPT_REPLACEMENT_KEY
public static final String MAX_KEYS_PREFIX
public static final String MAXPRE_KEY
public static final String MAXPOST_KEY
public static final String MAXIDLE_KEY
public static final String MAXJOBS_KEY
private String mJobName
org.griphyn.cPlanner.classes.SubInfo#jobName
protected String mNamespace
Namespace.isNamespaceValid(String)
public Dagman()
public Dagman(Map mp)
mp
- the initial map containing the profile keys for this namespace.public static boolean categoryRelatedKey(String key)
key
- the key in questionpublic String namespaceName()
namespaceName
in class Namespace
NAMESPACE_NAME
public void setJobName(String name)
name
- name of the job with which these profile keys are associated.public void construct(String key, String value)
public void checkKeyInNS(String key, String value)
checkKeyInNS
in class Namespace
key
- key that needs to be checked in the namespace for validity.value
- value of the keypublic int checkKey(String key, String value)
public String getPOSTScriptPath(String type)
type
- type of postscriptpublic void checkKeyInNS(PegasusProperties properties, String pool)
checkKeyInNS
in class Namespace
properties
- the PegasusProperties
object containing
all the properties that the user specified at various
places (like .chimerarc, properties file, command line).pool
- the pool name where the job is scheduled to run.public void assimilate(PegasusProperties properties, Profiles.NAMESPACES namespace)
assimilate
in class Namespace
profiles
- the Namespace
object containing the profiles.namespace
- the namespace for which the profiles need to be assimilated.public void merge(Namespace profiles)
public String toCondor()
public String toString(String name)
name
- the name of the condor job that contains these variables.protected StringBuffer append(StringBuffer sb, String key, String name, String value)
private boolean ignore(String key)
key
- the keyprivate String replacementKey(String key)
key
- the keyprivate String replacementValue(String key)
key
- the key