Mapper和Reducer的java抽象类

下面这幅图是mapReduce大体的运行过程。

开发MapReduce程序&＃xff0c;一共可以分为以上八个步骤。

其中每个步骤都是一个class类&＃xff0c;通过job对象将程序组装成一个任务提交即可。

为了简化MapReduce程序的开发&＃xff0c;每一个步骤的class类&＃xff0c;都有一个既定的父类&＃xff0c;直接继承即可。

因此可以大大简化MapReduce程序的开发难度&＃xff0c;也可以快速的实现功能开发。

MapReduce编程当中&＃xff0c;其中最重要的两个步骤就是Mapper类和Reducer类

Mapper抽象类

在hadoop2.x当中Mapper类是一个抽象类&＃xff0c;工程师只需要覆写一个java类&＃xff0c;继承自Mapper类即可&＃xff0c;然后重写里面的一些方法&＃xff0c;就可以实现特定的功能。
Mapper类当中比较重要的四个方法

1、setup方法&＃xff1a;
Mapper类当中的初始化方法&＃xff0c;程序中一些对象的初始化工作都可以放到这个方法里面来实现

2、map方法&＃xff1a;
读取的每一行数据&＃xff0c;都会来调用一次map方法&＃xff0c;这个方法也是最重要的方法&＃xff0c;可以通过这个方法来实现每一条数据的处理。

3、cleanup方法&＃xff1a;
在整个maptask执行完成之后&＃xff0c;会马上调用cleanup方法&＃xff0c;这个方法主要是做一些清理工作&＃xff0c;例如连接的断开&＃xff0c;资源的关闭等等

4、run方法&＃xff1a;
如果需要更精细的控制整个MapTask的执行&＃xff0c;那么可以覆写这个方法&＃xff0c;实现对所有的MapTask更精确的操作控制

Reducer抽象类

同样的道理&＃xff0c;在hadoop2.x当中&＃xff0c;reducer类也是一个抽象类&＃xff0c;抽象类允许工程师可以继承这个抽象类之后&＃xff0c;重新覆写抽象类当中的方法&＃xff0c;实现逻辑的自定义控制。
Reducer抽象类当中的四个抽象方法

1、setup方法&＃xff1a;
在ReduceTask初始化之后马上调用&＃xff0c;一些对象的初始化工作&＃xff0c;可以在这个类当中实现

2、reduce方法&＃xff1a;
所有从MapTask发送过来的数据&＃xff0c;都会调用reduce方法&＃xff0c;这个方法也是reduce当中最重要的方法&＃xff0c;可以通过这个方法实现数据的处理

3、cleanup方法&＃xff1a;
在整个ReduceTask执行完成之后&＃xff0c;会马上调用cleanup方法&＃xff0c;这个方法主要就是在reduce阶段做一些清理工作&＃xff0c;例如连接的断开&＃xff0c;资源的关闭等等

4、run方法&＃xff1a;
如果需要更精细的控制整个ReduceTask的执行&＃xff0c;那么可以覆写这个方法&＃xff0c;实现对所有的ReduceTask更精确的操作控制