rdd.glom()
对rdd的数据进行嵌套,嵌套按照分区来进行
rdd = sc.parallelize([1, 2, 3, 4, 5, 6, 7, 8, 9], 2)print(rdd.glom().collect())
输出:[[1,2,3,4],[5,6,7,8,9]]
参考
- PySpark基础入门(2):RDD及其常用算子_spark rdd 随机抽样-CSDN博客
对rdd的数据进行嵌套,嵌套按照分区来进行
rdd = sc.parallelize([1, 2, 3, 4, 5, 6, 7, 8, 9], 2)print(rdd.glom().collect())
输出:[[1,2,3,4],[5,6,7,8,9]]
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/587447.shtml
如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!