1.原文件
把原文件保存在E:linuxmapreduceinputyuangong这个路径下
2.统计每组的平均工资,且将平均工资大于850的数据输出到0分区,将850(含)输出到1分区。
首先要建一个Maven项目,然后再进行创建类
流程图:
(1)MyMapper类(Map处理阶段)
(2)MyReducer类(Reduce处理阶段)
(3)MyPartitioner类
(4)MyJob类
3.Ctrl + s 保存,右键运行
4.去E:linuxmapreduceoutputyuangong-out2这个目录下查看结果
5.双击打开这两个文件,查看内容
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)