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