zor*_*ork 2 scala apache-spark
如何连接所有列表:
org.apache.spark.rdd.RDD[List[Record]]
获得一个集合:
val values: org.apache.spark.rdd.RDD[Record]
有任何想法吗？
flatMap 那!
val rdd : org.apache.spark.rdd.RDD[List[Record]] = ???
val flattened = rdd.flatMap(identity)
identity身份功能在哪里f(x) => x
| 归档时间： |
|
| 查看次数： |
763 次 |
| 最近记录： |