public class ClassADSGenerator extends Object
Modifier and Type | Field and Description |
---|---|
static String |
BUILD_AD_KEY
The classad key for the pegasus build.
|
static String |
CORES_KEY
The key for the number of cores for the multiplier factor in stampede.
|
static String |
DAG_JOB_ID_KEY
The class ad for the jobId.
|
static String |
DAX_JOB_ID_KEY
The classad for generating the DAX ID
|
static String |
GENERATOR
The name of the generator.
|
static String |
GENERATOR_AD_KEY
The complete classad designating Pegasus as the generator.
|
static String |
JOB_CLASS_AD_KEY
The class ad for job Class.
|
static String |
JOB_CLUSTER_SIZE_AD_KEY
The class ad to designate the size of the clustered jobs.
|
static String |
JOB_RUNTIME_AD_KEY
The class ad for the expected job value
|
static String |
RESOURCE_AD_KEY
The class ad to store the execution pool at which the job is run.
|
static String |
ROOT_WF_UUID_KEY
The classad for the root workflow uuid
|
static String |
VERSION_AD_KEY
The class ad key for the version id.
|
static String |
WF_NAME_AD_KEY
The classad for the flow id.
|
static String |
WF_TIME_AD_KEY
The classad for the timestamp.
|
static String |
WF_UUID_KEY
The classad for the workflow uuid
|
static String |
XFORMATION_AD_KEY
The classad for the complete transformation name.
|
Constructor and Description |
---|
ClassADSGenerator() |
Modifier and Type | Method and Description |
---|---|
static void |
generate(PrintWriter writer,
ADag dag)
Writes out the classads for a workflow to corresponding writer stream.
|
static void |
generate(PrintWriter writer,
ADag dag,
Job job)
Writes out the classads for a job to corresponding writer stream.
|
private static String |
generateClassAdAttribute(String name,
int value)
Generates a classad attribute given the name and the value.
|
private static String |
generateClassAdAttribute(String name,
String value)
Generates a classad attribute given the name and the value.
|
private static String |
generateClassAdAttribute(String name,
String value,
boolean newLine)
Generates a classad attribute given the name and the value.
|
public static final String GENERATOR
public static final String GENERATOR_AD_KEY
public static final String VERSION_AD_KEY
org.griphyn.cPlanner.classes.DagInfo#releaseVersion
,
Constant Field Valuespublic static final String BUILD_AD_KEY
public static final String ROOT_WF_UUID_KEY
public static final String WF_UUID_KEY
public static final String WF_NAME_AD_KEY
org.griphyn.cPlanner.classes.DagInfo#flowIDName
,
Constant Field Valuespublic static final String WF_TIME_AD_KEY
org.griphyn.cPlanner.classes.DagInfo#mFlowTimestamp
,
Constant Field Valuespublic static final String XFORMATION_AD_KEY
public static final String DAX_JOB_ID_KEY
public static final String JOB_CLASS_AD_KEY
org.griphyn.cPlanner.classes.Job#jobClass
,
Constant Field Valuespublic static final String DAG_JOB_ID_KEY
org.griphyn.cPlanner.classes.Job#jobID
,
Constant Field Valuespublic static final String JOB_RUNTIME_AD_KEY
public static final String CORES_KEY
public static final String RESOURCE_AD_KEY
public static final String JOB_CLUSTER_SIZE_AD_KEY
public static void generate(PrintWriter writer, ADag dag)
writer
- is an open stream for the Condor submit file.dag
- the workflow object containing metadata about the workflow
like the workflow id and the release version.public static void generate(PrintWriter writer, ADag dag, Job job)
writer
- is an open stream for the Condor submit file.dag
- the workflow object containing metadata about the workflow
like the workflow id and the release version.job
- the Job
object for which the writer stream
is passed.private static String generateClassAdAttribute(String name, String value)
name
- the attribute name.value
- the value/expression making the classad attribute.private static String generateClassAdAttribute(String name, int value)
name
- the attribute name.value
- the value/expression making the classad attribute.private static String generateClassAdAttribute(String name, String value, boolean newLine)
name
- the attribute name.value
- the value/expression making the classad attribute.newLine
- boolean denoting whether to add a new line character at
start or not.