c******4
发帖数: 701 | 1 有几个命令不能用了
collectAsMap()为什么不能用在这里，但老版本可以
1. error: value collectAsMap is not a member of org.apache.spark.sql.
Dataset[(Any, Any)]
scala> val movieTitles = moviesDF.map(array => (array(0), array(1))).
collectAsMap()
:41: error: value collectAsMap is not a member of org.apache.spark.
sql.Dataset[(Any, Any)]
val movieTitles = moviesDF.map(array => (array(0), array(1))).
collectAsMap()
2. ++不能用在df里面了,新命令怎么查？
scala> val tmpTTData = notDelayFlights ++ delayedFlights
error: value ++ i... 阅读全帖 |
|
