架构第 12 周作业

分析如下 HiveQL，生成的 MapReduce 执行程序，map 函数输入是什么？输出是什么，reduce 函数输入是什么？输出是什么？

INSERT OVERWRITE TABLE pv_usersSELECT pv.pageid, u.ageFROM page_view pv   JOIN user u   ON (pv.userid = u.userid);

map 输入：两张表

map 输出：

111, <1, 1>

111, <1, 2>

222, <1, 1>

111, <2, 25>

222, <2, 32>

reduce 输入：

111, <1, 1>

111, <1, 2>

111, <2, 25>

222, <1, 1>

222, <2, 32>

reduce 输出：

1, 25

2, 25

1, 32