foreachPartition 报错

来源：9-13 -需求一统计结果写入到MySQL

花开北海

2019-02-22

这段代码

administrativeRanksInfoDF.orderBy(administrativeRanksDF.col("administrative_id")).cache()
administrativeRanksInfoDF.foreachPartition(partition => {
  partition.foreach(line => { //这一行报错
    println(line)
  })
})

执行报错，如下：
Error:(58, 9) value foreach is not a member of Object
p.foreach(t=>{

写回答

1回答

Michael_PK

2019-02-22

你先确认foreach是不是partition能点出来的方法，根据ide的提醒来写。上课的代码就参考git上的原来拷进来对比下

qq_海是倒过来的天_21

老哥，这个问题你解决了吗?

2020-02-24

共3条回复

以慕课网日志分析为例进入大数据Spark SQL的世界

快速转型大数据：Hadoop，Hive，SparkSQL步步为赢

1644 学习 · 1129 问题

查看课程

相似问题

dataset的foreachPartition方法有多个重载函数，引起编译错误

回答 3

关于foreachPartition

回答 1

将数据清洗存储到目标地址报错

回答 3

foreachPartition

回答 1

虽然数据导出来了，但是报错了，之前是正常的，加了saveAsTextFile后就报错了

回答 2

打开慕课网App查看更多内容