感谢各位,找到问题了,是我自己写的码有问题。
之前用python写的时候,reducebykey只要处理的是(k,v)形势的就可以,比如v是一个嵌套的list也可以处理。
但在scala里,不仅要是(k,v)格式的,还对k,v的类型有限制……,
如果v是一个list,就不会出现reducebykey的方法,把v转换成字符串,就能出现reducebykey的方法了。
###############
现在我是把k,v都转成字符串处理,如果v是一个复杂的嵌套的list,比如[[stra,dicta],[strb,dictb]]这种形式
只能转成字符串去处理吗?因为转成字符串,后面在处理时还要在转回来……
|