org.apache.hadoop.mapred.lib.aggregate

Class ValueAggregatorJobBase<K1 extends WritableComparable,V1 extends Writable>

java.lang.Object

org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase<K1,V1>

All Implemented Interfaces:

Closeable, AutoCloseable, JobConfigurable, Mapper<K1,V1,Text,Text>, Reducer<Text,Text,Text,Text>

Direct Known Subclasses:

ValueAggregatorCombiner, ValueAggregatorMapper, ValueAggregatorReducer

@InterfaceAudience.Public
@InterfaceStability.Stable
public abstract class ValueAggregatorJobBase<K1 extends WritableComparable,V1 extends Writable>
extends Object
implements Mapper<K1,V1,Text,Text>, Reducer<Text,Text,Text,Text>

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

Field Summary

Fields

Modifier and Type	Field and Description
protected ArrayList<ValueAggregatorDescriptor>	aggregatorDescriptorList

Constructor Summary

Constructors

Constructor and Description
ValueAggregatorJobBase()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
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

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException