org.apache.hadoop.mapred.lib.aggregate
Class ValueAggregatorJobBase

java.lang.Object
  org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase

All Implemented Interfaces:

Closeable, JobConfigurable, Mapper, Reducer

Direct Known Subclasses:

ValueAggregatorCombiner, ValueAggregatorMapper, ValueAggregatorReducer

public abstract class ValueAggregatorJobBase
extends Object
implements Mapper, Reducer

This abstract class implements some common functionalities of the the generic mapper, reducer and combiner classes of Abacus.

Field Summary

protected ArrayList<ValueAggregatorDescriptor>

aggregatorDescriptorList

Constructor Summary

ValueAggregatorJobBase()

Method Summary

void	close() Called after the last call to any other method on this object to free and/or flush resources.
void	configure(JobConf job) Initializes a new instance from a JobConf.
protected void	logSpec()

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

Field Detail

aggregatorDescriptorList

protected ArrayList<ValueAggregatorDescriptor> aggregatorDescriptorList

Constructor Detail

ValueAggregatorJobBase

public ValueAggregatorJobBase()

Method Detail

configure

public void configure(JobConf job)

Description copied from interface: JobConfigurable

Initializes a new instance from a JobConf.

Specified by:

configure in interface JobConfigurable

Parameters:

job - the configuration

logSpec

protected void logSpec()

close

public void close()
           throws IOException

Description copied from interface: Closeable

Called after the last call to any other method on this object to free and/or flush resources. Typical implementations do nothing.

Specified by:

close in interface Closeable

Throws:

IOException