使用复合键进行二次排序后保留特定条目

zengzsys  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(231)

我已经使用复合键(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方法来完成这个步骤?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题