edu.isi.pegasus.planner.namespace
public class Pegasus extends Namespace
Namespace.EmptyIterator
Modifier and Type | Field and Description |
---|---|
static String |
BUNDLE_KEY
The name of the key that if set, determines the number of super jobs
that are made corresponding to a logical transformation and an execution
pool.
|
static String |
BUNDLE_LOCAL_STAGE_IN_KEY
The name of the key that determines the bundling parameter for the
local stagein transfer node.
|
static String |
BUNDLE_LOCAL_STAGE_OUT_KEY
The name of the key that determines the bundling parameter for the
local stagein transfer node.
|
static String |
BUNDLE_REMOTE_STAGE_IN_KEY
The name of the key that determines the bundling parameter for the
remote stagein transfer node.
|
static String |
BUNDLE_REMOTE_STAGE_OUT_KEY
The name of the key that determines the bundling parameter for the
remote stagein transfer node.
|
static String |
BUNDLE_STAGE_IN_KEY
The name of the key that determines the bundling parameter for the
stagein transfer node.
|
static String |
BUNDLE_STAGE_OUT_KEY
The name of the key that determines the bundling parameter for the
stageout transfer node.
|
static String |
CHAIN_STAGE_IN_KEY
The name of the key that determines the number of chains of stagein
nodes that are to be created per site.
|
static String |
CHANGE_DIR_KEY
The name of the profile key that triggers the kickstart to change directory
before launching an executable instead of launching the executable from
the directory where kickstart is being run.
|
static String |
CLUSTER_ARGUMENTS
Arguments that need to be passed to the clustering executable.
|
static String |
CLUSTER_LOCAL_STAGE_IN_KEY
The name of the key that determines the cluster parameter for the
local stagein transfer node.
|
static String |
CLUSTER_LOCAL_STAGE_OUT_KEY
The name of the key that determines the cluster parameter for the
local stagein transfer node.
|
static String |
CLUSTER_REMOTE_STAGE_IN_KEY
The name of the key that determines the clustering parameter for the
stagein transfer node.
|
static String |
CLUSTER_REMOTE_STAGE_OUT_KEY
The name of the key that determines the bundling parameter for the
remote stagein transfer node.
|
static String |
CLUSTER_STAGE_IN_KEY
The name of the key that determines the clustering parameter for the
stagein transfer node.
|
static String |
CLUSTER_STAGE_OUT_KEY
The name of the key that determines the clustering parameter for the
stageout transfer node.
|
static String |
COLLAPSE_KEY
The name of the key that if set in the Pegasus namespace determines the
number of jobs that are collapsed into the super job.
|
static String |
COLLAPSER_KEY
Deprecated.
|
static String |
CONDOR_STYLE
The style indicating that the submit files are to be generated for
a vanilla condor execution.
|
static String |
CONDORC_STYLE
The style indicating that the submit files are to be generated for
a CondorC submission to remote schedds.
|
static String |
CORES_KEY
The number of cores that are associated with the job.
|
static String |
CREAMCE_STYLE
The style indicating that the submit files are to be generated for
a creamce submission
|
static String |
CREATE_AND_CHANGE_DIR_KEY
The name of the profile key that triggers the kickstart to create and
then the working directory to it before launching an executable.
|
static String |
DEPRECATED_BUNDLE_STAGE_IN_KEY
The deprecated bundle stagein key.
|
static String |
DEPRECATED_CHANGE_DIR_KEY
The deprecated change dir key.
|
static String |
GLIDEIN_STYLE
The style indicating that the submit files are to be generated for a
glidein execution.
|
static String |
GLIDEINWMS_STYLE
The style indicating that the submit files are to be generated for a
glideinwms execution.
|
static String |
GLITE_STYLE
The style indicating that the submit files are to be generated for a
glite execution.
|
static String |
GLOBUS_STYLE
The style indicating that the submit files are to be generated for
a CondorG execution.
|
static String |
GRIDSTART_ARGUMENTS_KEY
The name of the profile key, that determines the arguments with which
the GridStart that is used to launch a job on the remote site is invoked
with.
|
static String |
GRIDSTART_KEY
The name of the profile key that determines the launching executable
to be used to launch a job on the grid.
|
static String |
GRIDSTART_PATH_KEY
The name of the profile key that designates the path to a gridstart.
|
static String |
GROUP_KEY
The name of the profile key in vds namespace that does the grouping.
|
static String |
JOB_AGGREGATOR_KEY
The name of the key that determines the clusterig executable to be used
to run the merged/collapsed job.
|
static String |
JOB_RUN_TIME
The name of the key that if set in the Pegasus namespace specifies the
approximate runtime of the job.
|
static String |
LABEL_KEY
The name of the profile key in vds namespace that does the labelling
by default.
|
static String |
MAX_RUN_TIME
The name of the key that if set in the Pegasus namespace specifies the
maximum amount of time for which a cluster should run.
|
protected static Map |
mDeprecatedTable
The table containing the mapping of the deprecated keys to the newer keys.
|
protected String |
mNamespace
The name of the implementing namespace.
|
static String |
NAMESPACE_NAME
The name of the namespace that this class implements.
|
static String |
PMC_PRIORITY_KEY
A key to designate a priority to the jobs run by pegasus-mpi-cluster.
|
static String |
PMC_REQUEST_CPUS_KEY
A key to designate the number of CPU's requested by pegasus-mpi-cluster.
|
static String |
PMC_REQUEST_MEMORY_KEY
A key to designate the memory required by a job in MB by pegasus-mpi-cluster.
|
static String |
PMC_TASK_ARGUMENTS
Arguments that need to be passed to the PMC clustering executable.
|
static String |
REMOTE_INITIALDIR_KEY
The name of the key that sets a remote initial dir for a condor globus
job.
|
static String |
RUNTIME_KEY
The name of the profile key when associated with a transformation in the
transformation catalog gives expected runtime in seconds.
|
static String |
SSH_STYLE
The style indicating that the submit files are to be generated for a
direct ssh submission
|
static String |
STYLE_KEY
The name of the key, that denotes the style of the dag that is constructed.
|
private static Aggregator |
SUM_AGGREGATOR
Static Handle to the sum aggregator.
|
static String |
TRANSFER_ARGUMENTS_KEY
The name of the profile key, that when associated with transfer jobs
determines the arguments with which the transfer executable is invoked.
|
static String |
TRANSFER_PROXY_KEY
The name of the profile key if associated with a job, results in an explicit
transfer of the proxy from the submit host to the remote site, instead of
banking upon CondorG to transfer the proxy.
|
static String |
TYPE_KEY
The name of the key that denotes the type of the job.
|
static String |
WORKER_NODE_DIRECTORY_KEY
The directory in which job needs to execute on worker node tmp.
|
DEPRECATED_KEY, EMPTY_KEY, MALFORMED_KEY, mLogger, mProfileMap, NOT_PERMITTED_KEY, UNKNOWN_KEY, VALID_KEY, VERSION
Constructor and Description |
---|
Pegasus()
The default constructor.
|
Pegasus(Map mp)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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).
|
boolean |
containsKey(Object key)
Returns true if the namespace contains a mapping
for the specified key.
|
Map |
deprecatedTable()
Singleton access to the deprecated table that holds the deprecated keys,
and the keys that replace them.
|
Object |
get(Object key)
Returns the value to which this namespace maps the specified key.
|
boolean |
getBooleanValue(Object key)
Returns a boolean value, that a particular key is mapped to in this
namespace.
|
String |
getStringValue(Object key)
Returns a String value, that a particular key is mapped to in this
namespace.
|
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.
|
String |
toCondor()
Converts the contents of the map into the string that can be put in the
Condor file for printing.
|
void |
unknownKey(String key,
String value)
Warns about an unknown profile key and constructs it anyway.
|
assimilate, checkKeyInNS, checkKeyInNS, checkKeyInNS, checkKeyInNS, checkKeyInNS, deprecatedKey, emptyKey, getProfileKeyIterator, isEmpty, isNamespaceValid, keySet, malformedKey, notPermitted, removeKey, toString
public static final String NAMESPACE_NAME
public static final String REMOTE_INITIALDIR_KEY
public static final String BUNDLE_KEY
COLLAPSE_KEY
,
Constant Field Valuespublic static final String COLLAPSE_KEY
public static final String JOB_RUN_TIME
public static final String MAX_RUN_TIME
public static final String JOB_AGGREGATOR_KEY
public static final String COLLAPSER_KEY
public static final String GROUP_KEY
public static final String LABEL_KEY
public static final String GRIDSTART_KEY
public static final String GRIDSTART_ARGUMENTS_KEY
public static final String GRIDSTART_PATH_KEY
public static final String DEPRECATED_CHANGE_DIR_KEY
CHANGE_DIR_KEY
,
Constant Field Valuespublic static final String CHANGE_DIR_KEY
public static final String CREATE_AND_CHANGE_DIR_KEY
public static final String CORES_KEY
public static final String DEPRECATED_BUNDLE_STAGE_IN_KEY
CHANGE_DIR_KEY
,
Constant Field Valuespublic static final String BUNDLE_STAGE_IN_KEY
public static final String BUNDLE_REMOTE_STAGE_IN_KEY
public static final String BUNDLE_LOCAL_STAGE_IN_KEY
public static final String BUNDLE_REMOTE_STAGE_OUT_KEY
public static final String BUNDLE_LOCAL_STAGE_OUT_KEY
public static final String BUNDLE_STAGE_OUT_KEY
public static final String CLUSTER_STAGE_IN_KEY
public static final String CLUSTER_REMOTE_STAGE_IN_KEY
public static final String CLUSTER_LOCAL_STAGE_IN_KEY
public static final String CLUSTER_STAGE_OUT_KEY
public static final String CLUSTER_REMOTE_STAGE_OUT_KEY
public static final String CLUSTER_LOCAL_STAGE_OUT_KEY
public static final String CHAIN_STAGE_IN_KEY
public static final String TRANSFER_PROXY_KEY
public static final String TRANSFER_ARGUMENTS_KEY
public static final String RUNTIME_KEY
public static final String WORKER_NODE_DIRECTORY_KEY
public static final String CLUSTER_ARGUMENTS
public static final String STYLE_KEY
public static final String TYPE_KEY
public static final String CONDOR_STYLE
public static final String CONDORC_STYLE
public static final String CREAMCE_STYLE
public static final String GLOBUS_STYLE
public static final String GLIDEIN_STYLE
public static final String GLIDEINWMS_STYLE
public static final String GLITE_STYLE
public static final String SSH_STYLE
public static final String PMC_REQUEST_MEMORY_KEY
public static final String PMC_REQUEST_CPUS_KEY
public static final String PMC_PRIORITY_KEY
public static final String PMC_TASK_ARGUMENTS
private static Aggregator SUM_AGGREGATOR
protected String mNamespace
Namespace.isNamespaceValid(String)
protected static Map mDeprecatedTable
public Pegasus()
public Pegasus(Map mp)
mp
- the initial map.public String namespaceName()
namespaceName
in class Namespace
NAMESPACE_NAME
public void construct(String key, String value)
public int checkKey(String key, String value)
public 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.COLLAPSER_KEY
,
TRANSFER_PROXY_KEY
public void merge(Namespace profiles)
public Map deprecatedTable()
deprecatedTable
in class Namespace
public String toCondor()
public void unknownKey(String key, String value)
unknownKey
in class Namespace
key
- is the left-hand-sidevalue
- is the right hand sidepublic boolean containsKey(Object key)
containsKey
in class Namespace
key
- The key that you want to search for
in the namespace.public Object get(Object key)
public boolean getBooleanValue(Object key)
key
- The key whose boolean value you desire.public String getStringValue(Object key)
key
- The key whose boolean value you desire.