【发布时间】:2017-11-21 21:21:34
【问题描述】:
我有超过 50 列我想使用 spark SQL 计算总和。我不想手动编写每个列名。我怎样才能以编程方式做到这一点
【问题讨论】:
-
你能分享示例数据和预期输出吗?
标签: java apache-spark apache-spark-sql
我有超过 50 列我想使用 spark SQL 计算总和。我不想手动编写每个列名。我怎样才能以编程方式做到这一点
【问题讨论】:
标签: java apache-spark apache-spark-sql
类似
val addNums = df.columns.map(case (c) => df(c))
.reduce(_ + _)
val sumDF = df.select(expr(addNums).as("SumOfFifty"))
【讨论】: