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,Closeable,JobConfigurable,Mapper<K1,,V1, Text, Text> Reducer<Text,Text, Text, Text>
- Direct Known Subclasses:
ValueAggregatorCombiner,ValueAggregatorMapper,ValueAggregatorReducer
@Public
@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 Details
-
aggregatorDescriptorList
-
-
Constructor Details
-
ValueAggregatorJobBase
public ValueAggregatorJobBase()
-
-
Method Details
-
configure
Description copied from interface:JobConfigurableInitializes a new instance from aJobConf.- Specified by:
configurein interfaceJobConfigurable- Parameters:
job- the configuration
-
logSpec
protected void logSpec() -
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-