public class Braindump extends 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 String |
BRAINDUMP_FILE
The basename of the braindump file.
|
static String |
BUILD_KEY
The Key for the pegasus build.
|
static String |
DAX_INDEX_KEY
The dax index
|
static String |
DAX_LABEL_KEY
The DAX label.
|
static String |
DAX_VERRSION_KEY
The DAX version.
|
static String |
GENERATOR_TYPE_KEY
The Key designating type of Pegasus Code Generator.
|
static 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 String |
mSubmitFileDir
The directory where all the submit files are to be generated.
|
static String |
PLANNER_ARGUMENTS_KEY
The arguments passed to the planner.
|
static String |
PLANNER_VERSION_KEY
The Key for the planner version
|
static String |
PROPERTIES_KEY
The path to the pegasus properties file
|
static String |
ROOT_UUID_KEY
The key for UUID of the workflow.
|
static String |
SUBMIT_DIR_KEY
The submit directory for the workflow.
|
static String |
SUBMIT_HOSTNAME_KEY
The key for the submit hostname.
|
static String |
TIMESTAMP_KEY
The workflow timestamp.
|
static String |
USER_KEY
The user who submitted the workflow.
|
static String |
UUID_KEY
The key for UUID of the workflow.
|
static String |
VERSION_KEY
The Key for the version id.
|
static String |
WF_NAME_KEY
The Key for the flow id.
|
static String |
WF_TIME_KEY
The Key for the timestamp.
|
static String |
WF_TIMESTAMP_KEY
The Key for the timestamp.
|
Constructor and Description |
---|
Braindump() |
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
defaultBrainDumpEntries(ADag workflow)
Returns default braindump entries.
|
Collection<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.
|
Collection<File> |
generateCode(ADag dag,
Map<String,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 String |
getGridDN()
Returns the distinguished name from the proxy
|
protected String |
getSubmitHostname()
Returns the submit hostname
|
void |
initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
protected File |
writeOutBraindumpFile(Map<String,String> entries)
Writes out the braindump.txt file for a workflow in the submit
directory.
|
public static final String BRAINDUMP_FILE
public static final String GENERATOR_TYPE_KEY
public static final String USER_KEY
public static final String GRID_DN_KEY
public static final String PROPERTIES_KEY
public static final String SUBMIT_HOSTNAME_KEY
public static final String PLANNER_ARGUMENTS_KEY
public static final String ROOT_UUID_KEY
public static final String UUID_KEY
public static final String DAX_LABEL_KEY
public static final String DAX_INDEX_KEY
public static final String DAX_VERRSION_KEY
public static final String TIMESTAMP_KEY
public static final String SUBMIT_DIR_KEY
public static final String VERSION_KEY
org.griphyn.cPlanner.classes.DagInfo#releaseVersion
,
Constant Field Valuespublic static final String PLANNER_VERSION_KEY
public static final String BUILD_KEY
public static final String WF_NAME_KEY
org.griphyn.cPlanner.classes.DagInfo#flowIDName
,
Constant Field Valuespublic static final String WF_TIME_KEY
org.griphyn.cPlanner.classes.DagInfo#mFlowTimestamp
,
Constant Field Valuespublic static final String WF_TIMESTAMP_KEY
org.griphyn.cPlanner.classes.DagInfo#mFlowTimestamp
,
Constant Field Valuesprotected PegasusBag mBag
protected 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 Map<String,String> defaultBrainDumpEntries(ADag workflow) throws CodeGeneratorException
CodeGeneratorException
public Collection<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 Collection<File> generateCode(ADag dag, Map<String,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 File writeOutBraindumpFile(Map<String,String> entries) throws IOException
entries
- the Map containing the entries going into the braindump file.IOException
- in case of error while writing out file.protected String getSubmitHostname() throws CodeGeneratorException
CodeGeneratorException
protected String getGridDN()