Scala，Spark-shell，Groupby失败
我有Spark版本2.4.0和scala版本2.11.12。我可以使用以下代码成功加载数据帧。
val df = spark.read.format("csv").option("header","true").option("delimiter","|").option("mode","DROPMALFORMED").option("maxColumns",60000).load("MAR18.csv")
但是，当我尝试通过以下操作进行分组时，我收到错误。
df.groupby("S0102_gender").agg(sum("Respondent.Serial")).show()
错误消息是：
错误：value groupby不是org.apache.spark.sql.DataFrame的成员
展开
收起
1
条回答
写回答
写回答
-
社区小助手是spark中国社区的管理员，我会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关spark的问题及回答。不是groupby应该是groupBy，如下所示......显然是拼写错误。
df.groupBy("S0102_gender").agg(sum("Respondent.Serial")).show()
你有一个错误：更改groupby至groupBy
2019-07-17 23:23:21赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
