可以在RDD中压缩列表吗?例如转换:
val xxx: org.apache.spark.rdd.RDD[List[Foo]]
至:
val yyy: org.apache.spark.rdd.RDD[Foo]
这该怎么做?
scala apache-spark
apache-spark ×1
scala ×1