public class Braindump
extends java.lang.Object
wf_uuid submit_hostname planner_arguments user grid_dn dax_label timestamp submit_dir planner_version type propertiesAdditionally, the following duplicate keys exist till pegasus-run is modified.
old keyname -> new keyname ============================= label --> dax_label pegasus_wf_time --> timestamp run --> submit_dir pegasus_version --> planner_version
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BRAINDUMP_FILE
The basename of the braindump file.
|
static java.lang.String |
BUILD_KEY
The Key for the pegasus build.
|
static java.lang.String |
DAX_INDEX_KEY
The dax index
|
static java.lang.String |
DAX_LABEL_KEY
The DAX label.
|
static java.lang.String |
DAX_VERRSION_KEY
The DAX version.
|
static java.lang.String |
GENERATOR_TYPE_KEY
The Key designating type of Pegasus Code Generator.
|
static java.lang.String |
GRID_DN_KEY
The Grid DN of the user.
|
protected PegasusBag |
mBag
The bag of initialization objects.
|
protected LogManager |
mLogger
The handle to the logging object.
|
protected PlannerOptions |
mPOptions
The object containing the command line options specified to the planner
at runtime.
|
protected PegasusProperties |
mProps
The object holding all the properties pertaining to Pegasus.
|
protected java.lang.String |
mSubmitFileDir
The directory where all the submit files are to be generated.
|
static java.lang.String |
PLANNER_ARGUMENTS_KEY
The arguments passed to the planner.
|
static java.lang.String |
PLANNER_VERSION_KEY
The Key for the planner version
|
static java.lang.String |
PROPERTIES_KEY
The path to the pegasus properties file
|
static java.lang.String |
ROOT_UUID_KEY
The key for UUID of the workflow.
|
static java.lang.String |
SUBMIT_DIR_KEY
The submit directory for the workflow.
|
static java.lang.String |
SUBMIT_HOSTNAME_KEY
The key for the submit hostname.
|
static java.lang.String |
TIMESTAMP_KEY
The workflow timestamp.
|
static java.lang.String |
USER_KEY
The user who submitted the workflow.
|
static java.lang.String |
UUID_KEY
The key for UUID of the workflow.
|
static java.lang.String |
VERSION_KEY
The Key for the version id.
|
static java.lang.String |
WF_NAME_KEY
The Key for the flow id.
|
static java.lang.String |
WF_TIME_KEY
The Key for the timestamp.
|
static java.lang.String |
WF_TIMESTAMP_KEY
The Key for the timestamp.
|
Constructor and Description |
---|
Braindump() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.lang.String> |
defaultBrainDumpEntries(ADag workflow)
Returns default braindump entries.
|
java.util.Collection<java.io.File> |
generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
void |
generateCode(ADag dag,
Job job)
Method not implemented.
|
java.util.Collection<java.io.File> |
generateCode(ADag dag,
java.util.Map<java.lang.String,java.lang.String> additionalEntries)
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
protected java.lang.String |
getGridDN()
Returns the distinguished name from the proxy
|
protected java.lang.String |
getSubmitHostname()
Returns the submit hostname
|
void |
initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
protected java.io.File |
writeOutBraindumpFile(java.util.Map<java.lang.String,java.lang.String> entries)
Writes out the braindump.txt file for a workflow in the submit
directory.
|
public static final java.lang.String BRAINDUMP_FILE
public static final java.lang.String GENERATOR_TYPE_KEY
public static final java.lang.String USER_KEY
public static final java.lang.String GRID_DN_KEY
public static final java.lang.String PROPERTIES_KEY
public static final java.lang.String SUBMIT_HOSTNAME_KEY
public static final java.lang.String PLANNER_ARGUMENTS_KEY
public static final java.lang.String ROOT_UUID_KEY
public static final java.lang.String UUID_KEY
public static final java.lang.String DAX_LABEL_KEY
public static final java.lang.String DAX_INDEX_KEY
public static final java.lang.String DAX_VERRSION_KEY
public static final java.lang.String TIMESTAMP_KEY
public static final java.lang.String SUBMIT_DIR_KEY
public static final java.lang.String VERSION_KEY
org.griphyn.cPlanner.classes.DagInfo#releaseVersion
,
Constant Field Valuespublic static final java.lang.String PLANNER_VERSION_KEY
public static final java.lang.String BUILD_KEY
public static final java.lang.String WF_NAME_KEY
org.griphyn.cPlanner.classes.DagInfo#flowIDName
,
Constant Field Valuespublic static final java.lang.String WF_TIME_KEY
org.griphyn.cPlanner.classes.DagInfo#mFlowTimestamp
,
Constant Field Valuespublic static final java.lang.String WF_TIMESTAMP_KEY
org.griphyn.cPlanner.classes.DagInfo#mFlowTimestamp
,
Constant Field Valuesprotected PegasusBag mBag
protected java.lang.String mSubmitFileDir
protected PegasusProperties mProps
protected PlannerOptions mPOptions
protected LogManager mLogger
public void initialize(PegasusBag bag) throws CodeGeneratorException
bag
- the bag of initialization objects.CodeGeneratorException
- in case of any error occuring code generation.public java.util.Map<java.lang.String,java.lang.String> defaultBrainDumpEntries(ADag workflow) throws CodeGeneratorException
CodeGeneratorException
public java.util.Collection<java.io.File> generateCode(ADag dag) throws CodeGeneratorException
dag
- the concrete workflow.File
objects for the files written
out.CodeGeneratorException
- in case of any error occuring code generation.public java.util.Collection<java.io.File> generateCode(ADag dag, java.util.Map<java.lang.String,java.lang.String> additionalEntries) throws CodeGeneratorException
dag
- the concrete workflow.additionalEntries
- additional entries to go in the braindump file,
overwriting the default entries.File
objects for the files written
out.CodeGeneratorException
- in case of any error occuring code generation.public void generateCode(ADag dag, Job job) throws CodeGeneratorException
dag
- the workflowjob
- the job for which the code is to be generated.CodeGeneratorException
protected java.io.File writeOutBraindumpFile(java.util.Map<java.lang.String,java.lang.String> entries) throws java.io.IOException
entries
- the Map containing the entries going into the braindump file.java.io.IOException
- in case of error while writing out file.protected java.lang.String getSubmitHostname() throws CodeGeneratorException
CodeGeneratorException
protected java.lang.String getGridDN()