一、概念说明 学过MySQL的都知道,join和left join 这里的join含义和MySQL的join含义一样 就是对两张表的数据,进行关联查询 Hadoop的MapReduce阶段,分为2个阶段 一个Map,一个Reduce 那么,join逻辑,就可以在这两个阶段实现。 两者有什么区别了? 我们都知道,一般情况下,MapTask比ReduceTask线程数更多。 所以,当两张表,有一个表数据量非常大,一个表非常小的时候 我们建议放在Map阶段进行join,这样可以提高性能。 二、需求说明 有两张表数据 将商品信息表中数据根据商品pid合并到订单数据表中 三、代码实现 TableBean package com.atguigu.mapreduce.reduceJoin; import org.apache.hadoop.io.Writable; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; public class TableBean implements...