public class NetloggerJobMapper
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private LogFormatter |
mLogFormatter
The handle to the netlogger log formatter.
|
private LogManager |
mLogger
The handle to pegasus logger used for run.
|
static java.lang.String |
NETLOGGER_LOG_FORMATTER_IMPLEMENTOR |
Constructor and Description |
---|
NetloggerJobMapper(LogManager logger)
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
private java.lang.String |
generateLogEvent(Job job,
java.lang.String prefix)
Generates a log event message in the netlogger format for a job
|
private java.lang.String |
getKey(java.lang.String prefix,
java.lang.String key)
Adds a prefix to the key and returns it.
|
private int |
getTaskCount(Job job)
Returns the task count for a job.
|
void |
writeOutMappings(java.io.Writer writer,
ADag dag)
Writes out the job mappings for a workflow.
|
public static final java.lang.String NETLOGGER_LOG_FORMATTER_IMPLEMENTOR
private LogFormatter mLogFormatter
private LogManager mLogger
public NetloggerJobMapper(LogManager logger)
logger
- the logger instance to use for loggingpublic void writeOutMappings(java.io.Writer writer, ADag dag) throws java.io.IOException
writer
- the writer stream to which to write out the mappingsdag
- the dag for which to write out the mappingsjava.io.IOException
private java.lang.String generateLogEvent(Job job, java.lang.String prefix)
job
- the jobprefix
- prefix if any to add to the keysprivate java.lang.String getKey(java.lang.String prefix, java.lang.String key)
prefix
- the prefix to be addedkey
- the keyprivate int getTaskCount(Job job)
job
-