我已经使用复合键(hadoopmapreducejava)进行了二次排序。排序后的数据如下所示:
(asec) (desc) (asec)
id num price
1 10 9
1 10 10
1 8 7
2 10 9
2 8 12
(id,num)是复合键。
预期结果是:
id num price
1 10 9
2 10 9
也就是说,对于每个id,获取最大num和最低价格(如果有相同的最大num)。
我应该如何编写reduce方法来完成这个步骤?
暂无答案!
目前还没有任何答案,快来回答吧!