【问题标题】:Spark SQL - Sum multiple columns in single query JAVASpark SQL - 在单个查询 JAVA 中对多列求和
【发布时间】:2017-11-21 21:21:34
【问题描述】:

我有超过 50 列我想使用 spark SQL 计算总和。我不想手动编写每个列名。我怎样才能以编程方式做到这一点

【问题讨论】:

  • 你能分享示例数据和预期输出吗?

标签: java apache-spark apache-spark-sql


【解决方案1】:

类似

val addNums = df.columns.map(case (c) => df(c))
                .reduce(_ + _)

val sumDF =  df.select(expr(addNums).as("SumOfFifty"))

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2017-11-14
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2012-04-20
    • 2022-02-03
    相关资源
    最近更新 更多