public class MonitordNotify extends java.lang.Object implements CodeGenerator
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DAG_JOB
The constant string to write for dag job notifications.
|
static java.lang.String |
DAX_JOB
The constant string to write for dax job notifications.
|
static java.lang.String |
DELIMITER
The delimiter with which to separate different fields in the
notifications file.
|
static java.lang.String |
INVOCATION
The constant string to write for invocation notifications.
|
static java.lang.String |
JOB
The constant string to write for job notifications.
|
protected PegasusBag |
mBag
The bag of initialization objects.
|
protected LogManager |
mLogger
The handle to the logging object.
|
private java.io.PrintWriter |
mNotificationsWriter
The handle to the PrintWriter that writes out the notifications file
|
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 |
NOTIFICATIONS_FILE_SUFFIX
The suffix to use while constructing the name of the metrics file
|
static java.lang.String |
WORKFLOW
The constant string to write for work flow notifications.
|
VERSION
Constructor and Description |
---|
MonitordNotify() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<java.io.File> |
generateCode(ADag dag)
Generates the notifications input file.
|
void |
generateCode(ADag dag,
Job job)
Not implemented
|
void |
initialize(PegasusBag bag)
Initializes the Code Generator implementation.
|
void |
reset()
Not implemented
|
boolean |
startMonitoring()
Not implemented
|
public static final java.lang.String NOTIFICATIONS_FILE_SUFFIX
public static final java.lang.String WORKFLOW
public static final java.lang.String JOB
public static final java.lang.String INVOCATION
public static final java.lang.String DAG_JOB
public static final java.lang.String DAX_JOB
public static final java.lang.String DELIMITER
protected PegasusBag mBag
protected java.lang.String mSubmitFileDir
protected PegasusProperties mProps
protected PlannerOptions mPOptions
protected LogManager mLogger
private java.io.PrintWriter mNotificationsWriter
public void initialize(PegasusBag bag) throws CodeGeneratorException
initialize
in interface CodeGenerator
bag
- the bag of initialization objects.CodeGeneratorException
- in case of any error occurring code generation.public java.util.Collection<java.io.File> generateCode(ADag dag) throws CodeGeneratorException
generateCode
in interface CodeGenerator
dag
- the concrete work-flow.File
objects for the files written
out.CodeGeneratorException
- in case of any error occurring code generation.public void generateCode(ADag dag, Job job) throws CodeGeneratorException
generateCode
in interface CodeGenerator
dag
- the work-flowjob
- the job for which the code is to be generated.CodeGeneratorException
public boolean startMonitoring()
startMonitoring
in interface CodeGenerator
public void reset() throws CodeGeneratorException
reset
in interface CodeGenerator
CodeGeneratorException
- in case of any error occuring code generation.