![]() |
1
1
过滤阶段不会更改RDD的类型(即
因此,您可以使用映射阶段对过滤器阶段返回的RDD进行管道处理,并以与过滤阶段相同的方式处理每条记录:
我认为您被collect阶段误导了,该阶段将RDD转换为数组。 |
![]() |
Bruno Peixoto · Spark群集CI管道构建失败 1 年前 |
![]() |
mcsilvio · 在foreach中组织联接的最佳方式是什么? 1 年前 |
![]() |
Dhruv · 在sbt控制台上运行Spark 1 年前 |
![]() |
Leonard · Pyspark:JSON到Pyspark数据帧 1 年前 |
![]() |
billie class · 将列中的值重写为列表中的下一个值 2 年前 |