scala - 从scala中的数据框中添加两列

Question

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

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

给我错误。请帮忙

Answer 1

以下spark是 的实例SparkSession，因此导入必须在的实例化之后进行spark。

$-notation可以在这里通过导入 spark 隐式使用

import spark.implicits._ 

然后使用 $-notation

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

最终的scala代码：

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

阿帕奇文档