context.key(k,v)中的k是自定义对象问题? 400 报错-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

context.key(k,v)中的k是自定义对象问题? 400 报错

爱吃鱼的程序员 2020-06-04 14:30:12 122

context.key(k,v)中的k是自定义对象问题? 400 报错

@超人学院 你好,想跟你请教个问题:

 k如果是String的话,hadoop可以做到把相同的字符串合并成
(a,1),(a,2),(a,3),(a,4) -> (a,(1,2,3,4))
 像现在,我的k如果是个对象,hadoop能按照我定义的equals进行合并吗?
 就想这样((a1,b1,c1),1),((a1,b1,c1),2),((a1,b1,c1),3) -> ((a1,b1,c1),(1,2,3))
待处理数据集:

目前的错误结果:

其实想要的结果是类似这样的:

tom yuwen 264

tom shuxue 300

tom yingyu 400

lucy yuwen 456

lucy shuxue 456

lucy yingyu 566

......................

分享到
取消 提交回答
全部回答(1)
  • 爱吃鱼的程序员
    2020-06-04 16:10:30

    K是对象你要实现hadoop的compare接口实现里面的compareTo方法

    0 0
云计算
使用钉钉扫一扫加入圈子
+ 订阅

时时分享云计算技术内容,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。

推荐文章