2

想法中

版本: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 就可以了

所以有什么问题?

4

0 回答 0