大数据之Hadoop3.x_MapReduce_ReduceJoin案例Reducer_案例完成大数据之hadoop3.x工作笔记0131

然后我们再去写reducer

首先输入的参数就是map输出的参数对吧是,Text,TableBean

Text是key也就是商品的pid,然后TableBean是数据也就是我们封装的数据对象

然后reduce的输出呢?

可以看到我们只需要,输出原来order.txt中的数据,把order.txt中数据存储用的TableBean作为

key,然后value呢?

我们不需要对吧,不需要就可以设置成NullWritable

然后去重写reduce方法,我们可以copy过来一组数据作为参考

可以看到pid作为key,然后一组数据中,只有一个数据是来至pd.txt的

因为pd的数据是,pid类似个主键对吧,是商品id