开发者学堂课程【Hadoop 分布式计算框架 MapReduce:MapJoin 案例测试】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/94/detail/1552
MapJoin 案例测试
一、操作过程
1、获取一行
String line = value.toString();
拿到这一行之后,要从中取出pid,然后到pname中获取内容
2、切割
String[ ] fileds = line.split("\t");
3、获取 pid
String pid = fileds[1];
4、取出 pname
String pname = pdMap.get(pid);
5、拼接
line = line +"\t"+ pname;
K.set(line);
6、写作
context.write(k,NullWritable.get());