org.apache.hadoop.contrib.utils.join

类 JobBase

java.lang.Object

org.apache.hadoop.contrib.utils.join.JobBase

所有已实现的接口:

Closeable, AutoCloseable, JobConfigurable, Mapper, Reducer

直接已知子类:

DataJoinMapperBase, DataJoinReducerBase

public abstract class JobBase
extends Object
implements Mapper, Reducer

A common base implementing some statics collecting mechanisms that are commonly used in a typical map/reduce job.

字段概要

字段

限定符和类型	字段和说明
static org.apache.commons.logging.Log	LOG

构造器概要

构造器

构造器和说明
JobBase()

方法概要

方法

限定符和类型	方法和说明
protected Double	addDoubleValue(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 Long	addLongValue(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 Double	getDoubleValue(Object name)
protected Long	getLongValue(Object name)
protected String	getReport() log the counters
protected void	report() log the counters
protected void	setDoubleValue(Object name, double value) Set the given counter to the given value
protected void	setLongValue(Object name, long value) Set the given counter to the given value

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.mapred.Mapper

map

从接口继承的方法 org.apache.hadoop.mapred.Reducer

reduce

从接口继承的方法 java.io.Closeable

close

字段详细资料

LOG

public static final org.apache.commons.logging.Log LOG

构造器详细资料

JobBase

public JobBase()

方法详细资料

setLongValue

protected void setLongValue(Object name,
                long value)

Set the given counter to the given value

参数:

name - the counter name

value - the value for the counter

setDoubleValue

protected void setDoubleValue(Object name,
                  double value)

Set the given counter to the given value

参数:

name - the counter name

value - the value for the counter

getLongValue

protected Long getLongValue(Object name)

参数:

name - the counter name

返回:

return the value of the given counter.

getDoubleValue

protected Double getDoubleValue(Object name)

参数:

name - the counter name

返回:

return the value of the given counter.

addLongValue

protected Long addLongValue(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.

参数:

name - the counter name

inc - the incremental value

返回:

the updated value.

addDoubleValue

protected Double addDoubleValue(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.

参数:

name - the counter name

inc - the incremental value

返回:

the updated value.

report

protected void report()

log the counters

getReport

protected String getReport()

log the counters

configure

public void configure(JobConf job)

Initializes a new instance from a JobConf.

指定者:

configure 在接口中 JobConfigurable

参数:

job - the configuration