赞
踩
继承Mapper类可以重写三个方法
1.setup
每一个map在创建时执行的方法,也就是说该方法只执行一次,一般用来做一些准备工作,如获得文件名等
2.map
真正执行分类操作的方法。
3.cleanup
在map完成任务销毁时执行的方法,也只执行一次,一般用来做一些收尾工作
这三个方法都可以像reduce传送数据
代码 取每个电影二十条数据(排序前面写过了,就不写了):
要注意map的个数,如果有多个map,会取出超过二十条数据
- package nuc.edu.ls;
-
- import java.io.DataInput;
- import java.io.DataOutput;
- import java.io.IOException;
-
- import org.apache.hadoop.io.Writable;
- import org.apache.hadoop.io.WritableComparable;
-
- public class MovieBean implements WritableComparable<MovieBean>{
- private String movie;
- private String rate;
- private String timeStamp;
- private String uid;
-
- public String getMovie() {
- return movie;
- }
- public void setMovie(String movie) {
- this.movie = movie;
- }
- public String getRate() {
- return rate;
- }
- public void setRate(String rate) {
- this.rate = rate;
- }
- public String getTimeStamp() {
- return timeStamp;
- }
- public void setTimeStamp(String timeStamp) {
- this.timeStamp = timeStamp;
- }
- public String getUid() {
- return uid;
- }
- public void setUid(String uid) {
- this.uid = uid;
- }
-
- public void set(String movie, String rate, String timeStamp, String uid) {
- this.movie = movie;
- this.rate = rate;
- this.ti

Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。