public class MonitordNotify extends Object implements CodeGenerator
Modifier and Type | Field and Description |
---|---|
static String |
DAG_JOB
The constant string to write for dag job notifications.
|
static String |
DAX_JOB
The constant string to write for dax job notifications.
|
static String |
DELIMITER
The delimiter with which to separate different fields in the
notifications file.
|
static String |
INVOCATION
The constant string to write for invocation notifications.
|
static 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 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 String |
mSubmitFileDir
The directory where all the submit files are to be generated.
|
static String |
NOTIFICATIONS_FILE_SUFFIX
The suffix to use while constructing the name of the metrics file
|
static String |
WORKFLOW
The constant string to write for work flow notifications.
|
VERSION
Constructor and Description |
---|
MonitordNotify() |
Modifier and Type | Method and Description |
---|---|
Collection<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 String NOTIFICATIONS_FILE_SUFFIX
public static final String WORKFLOW
public static final String JOB
public static final String INVOCATION
public static final String DAG_JOB
public static final String DAX_JOB
public static final String DELIMITER
protected PegasusBag mBag
protected String mSubmitFileDir
protected PegasusProperties mProps
protected PlannerOptions mPOptions
protected LogManager mLogger
private 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 Collection<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.Copyright © 2011 The University of Southern California. All Rights Reserved.