一文详解pyspark常用算子与API

2023-12-31 15:50:20

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]]

参考

文章来源:https://blog.csdn.net/qq_32862515/article/details/135316156
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。