| Package | Description | 
|---|---|
| org.apache.hadoop.mapred | |
| org.apache.hadoop.mapred.lib | |
| org.apache.hadoop.mapred.lib.aggregate | 
| Modifier and Type | Method and Description | 
|---|---|
| protected Mapper<K1,V1,K2,V2> | MapRunner. getMapper() | 
| Modifier and Type | Method and Description | 
|---|---|
| Class<? extends Mapper> | JobConf. getMapperClass()Get the  Mapperclass for the job. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | JobConf. setMapperClass(Class<? extends Mapper> theClass)Set the  Mapperclass for the job. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ChainMapperThe ChainMapper class allows to use multiple Mapper classes within a single
 Map task. | 
| class  | DelegatingMapper<K1,V1,K2,V2>An  Mapperthat delegates behaviour of paths to multiple other
 mappers. | 
| class  | FieldSelectionMapReduce<K,V>This class implements a mapper/reducer class that can be used to perform
 field selections in a manner similar to unix cut. | 
| class  | IdentityMapper<K,V>Implements the identity function, mapping inputs directly to outputs. | 
| class  | InverseMapper<K,V>A  Mapperthat swaps keys and values. | 
| class  | RegexMapper<K>A  Mapperthat extracts text matching a regular expression. | 
| class  | TokenCountMapper<K>A  Mapperthat maps text values into <token,freq> pairs. | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | MultipleInputs. addInputPath(JobConf conf,
            org.apache.hadoop.fs.Path path,
            Class<? extends InputFormat> inputFormatClass,
            Class<? extends Mapper> mapperClass) | 
| static <K1,V1,K2,V2>  | ChainReducer. addMapper(JobConf job,
         Class<? extends Mapper<K1,V1,K2,V2>> klass,
         Class<? extends K1> inputKeyClass,
         Class<? extends V1> inputValueClass,
         Class<? extends K2> outputKeyClass,
         Class<? extends V2> outputValueClass,
         boolean byValue,
         JobConf mapperConf)Adds a Mapper class to the chain job's JobConf. | 
| static <K1,V1,K2,V2>  | ChainMapper. addMapper(JobConf job,
         Class<? extends Mapper<K1,V1,K2,V2>> klass,
         Class<? extends K1> inputKeyClass,
         Class<? extends V1> inputValueClass,
         Class<? extends K2> outputKeyClass,
         Class<? extends V2> outputValueClass,
         boolean byValue,
         JobConf mapperConf)Adds a Mapper class to the chain job's JobConf. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | ValueAggregatorCombiner<K1 extends org.apache.hadoop.io.WritableComparable,V1 extends org.apache.hadoop.io.Writable>This class implements the generic combiner of Aggregate. | 
| class  | ValueAggregatorJobBase<K1 extends org.apache.hadoop.io.WritableComparable,V1 extends org.apache.hadoop.io.Writable>This abstract class implements some common functionalities of the
 the generic mapper, reducer and combiner classes of Aggregate. | 
| class  | ValueAggregatorMapper<K1 extends org.apache.hadoop.io.WritableComparable,V1 extends org.apache.hadoop.io.Writable>This class implements the generic mapper of Aggregate. | 
| class  | ValueAggregatorReducer<K1 extends org.apache.hadoop.io.WritableComparable,V1 extends org.apache.hadoop.io.Writable>This class implements the generic reducer of Aggregate. | 
Copyright © 2022 Apache Software Foundation. All rights reserved.