如何将 Spark RDD[Array[MyObject]] 转换为 RDD[MyObject]

Question

如何将 Spark RDD[Array[MyObject]] 转换为 RDD[MyObject]？

Answer 1

您正在寻找 RDD.flatMap:

val flattened: RDD[MyObject] = rdd.flatMap(identity)