|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.contrib.utils.join.JobBase
public abstract class JobBase
A common base implementing some statics collecting mechanisms that are commonly used in a typical map/reduce job.
Field Summary | |
---|---|
static org.apache.commons.logging.Log |
LOG
|
Constructor Summary | |
---|---|
JobBase()
|
Method Summary | |
---|---|
protected java.lang.Double |
addDoubleValue(java.lang.Object name,
double inc)
Increment the given counter by the given incremental value If the counter does not exist, one is created with value 0. |
protected java.lang.Long |
addLongValue(java.lang.Object name,
long inc)
Increment the given counter by the given incremental value If the counter does not exist, one is created with value 0. |
void |
configure(JobConf job)
Initializes a new instance from a JobConf . |
protected java.lang.Double |
getDoubleValue(java.lang.Object name)
|
protected java.lang.Long |
getLongValue(java.lang.Object name)
|
protected java.lang.String |
getReport()
log the counters |
protected void |
report()
log the counters |
protected void |
setDoubleValue(java.lang.Object name,
double value)
Set the given counter to the given value |
protected void |
setLongValue(java.lang.Object name,
long value)
Set the given counter to the given value |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.hadoop.mapred.Mapper |
---|
map |
Methods inherited from interface org.apache.hadoop.mapred.Reducer |
---|
reduce |
Methods inherited from interface java.io.Closeable |
---|
close |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
Constructor Detail |
---|
public JobBase()
Method Detail |
---|
protected void setLongValue(java.lang.Object name, long value)
name
- the counter namevalue
- the value for the counterprotected void setDoubleValue(java.lang.Object name, double value)
name
- the counter namevalue
- the value for the counterprotected java.lang.Long getLongValue(java.lang.Object name)
name
- the counter name
protected java.lang.Double getDoubleValue(java.lang.Object name)
name
- the counter name
protected java.lang.Long addLongValue(java.lang.Object name, long inc)
name
- the counter nameinc
- the incremental value
protected java.lang.Double addDoubleValue(java.lang.Object name, double inc)
name
- the counter nameinc
- the incremental value
protected void report()
protected java.lang.String getReport()
public void configure(JobConf job)
JobConf
.
configure
in interface JobConfigurable
job
- the configuration
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |