从scala中的数据框添加两列

发布时间：2020-12-16 10:05:44 所属栏目：安全来源：网络整理

导读：我有两列年龄和薪水存储在DF中.我只想编写一个 scala代码来逐列添加这些值.我试过了 val age_1 = df.select("age")val salary_1=df.select("salary")val add = age_1+salary_1 给我错误.请帮忙解决方法在下面的spark是SparkSession的一个实例,因此导入必须

我有两列年龄和薪水存储在DF中.我只想编写一个 scala代码来逐列添加这些值.我试过了

val age_1 = df.select("age")
val salary_1=df.select("salary")
val add = age_1+salary_1

给我错误.请帮忙

解决方法

在下面的spark是SparkSession的一个实例,因此导入必须在spark实例化之后.

这里可以通过导入spark implicits来使用$-notation

import spark.implicits._

然后使用$-notation

val add = df.select($"age" + $"salary")

最终的scala代码：

import spark.implicits._
val add = df.select($"age" + $"salary")

Apache doc

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!