可以在RDD partition 中创建[k, v] pairs吗
【可以在RDD partition 中创建[k, v] pairs吗】 答主修改过题目之后仍然是靠少数示例而不是精确的定义来说明输入输出，因此我仍然不是很确定到底是要干什么……连蒙带猜感觉要的是这个？val data = https://www.zhihu.com/api/v4/questions/59703959/Seq( 1 -/u0026gt; Seq(4, 11, 3, 333, 3, 222), 2 -/u0026gt; Seq(5, 6, 5, 44))val rdd = sc.parallelize(data)val resRdd = rdd .flatMap { case (_, values) =/u0026gt; values.grouped(2) } .map { case Seq(key, value) =/u0026gt; key -/u0026gt; Seq(value) } .reduceByKey { _ ++ _ } .collect()
■网友
问题好怪啊。。。用 mapPartitions 吧？
■网友
没看懂问题。你试过map或者flatMap吗？
推荐阅读
![[快递]快递柜里不少包裹“睡懒觉”，快递小哥提醒：错峰取件](http://res.cjrbapp.cjn.cn/a/10001/202002/bef13647f7d3b3bd82846e4d9127587f.jpeg)
- 哪个网站可以在线阅读台湾和香港的杂志或者报纸
- 有啥IT方面的兼职可以在家做吗
- iphone咋续保！！
- 当今中国不应该立法规制人肉搜索
- 怎么样评价MSN退出中国为啥国外的即时社交工具难以在中国生存
- 是否可以在美国对百度提起集体诉讼
- 用车|左转红灯、直行绿灯，可以在左转待转区掉头吗？|红灯|信号灯|左转灯|转区|绿灯
- c++可以在同一个内存位置替换对象么
- 就360败诉这件事分析中国现今的互联网创业环境，在BAT三巨头的垄断下是否真的难以在中国创业
- 一个精通算法设计的工程师可以在量化投资团队中扮演啥角色