首页 > 解决方案 > 如何在不创建新数据框的情况下向我的 Scala 数据框添加列

问题描述

这是迄今为止我对选定列进行逐行平均的代码。

val df2 = df1.select(num_columns.map(col).reduce((c1,c2) => c1 + c2) as "sum")
  .select("sum")
  .withColumn("avg",(col("sum")/num_cols.length))

但是,我只想将“avg”列添加到 df1,而不是创建 df2。但是,每当我使用 withColumn 尝试相同的代码时,它都不起作用。

在 df1 中简单地创建相同的“avg”列的语法是什么?

标签: scalaapache-spark

解决方案


推荐阅读