基于MapReduce的并行程序设计

自定义Mapper类设计与实现

    class TokenizerMapper
    extends Mapper<Object, Text, Text, IntWritable>
    ｛ … }
    
    
      
      
      
    

1. 所有自定义的mapper类都需要继承Mapper类，该类包含四个类型参数，具体如下：

• Object：输入键的类型-------------K1
• Text：输入值的类型-----------V1
• Text：输出键的类型-----------K2
• IntWritable：输出值的类型—V2

2. 在设计自定义mapper类时，必须继承Mapper类，并对map方法进行重写；

3. 对单行数据进行一次映射函数的执行操作；

自定义Reducer类设计与实现

    class IntSumReducer
    extends Reducer<Text, IntWritable, Text, IntWrita