想法中
版本:spark3.0.1,scala2.12.12,java1.8.0_212
我的代码:
val df=spark.range(10)
df.foreachParitition(rows=>{
rows.foreach(.......)
})
错误:
value foreach is not a member of Object
rows.foreach(row=>{
如果使用 spark2.4.7 和 scala2.11 就可以了
所以有什么问题?