scala – 如何按列在Spark SQL中按降序排序？

发布时间：2020-12-16 09:48:01 所属栏目：安全来源：网络整理

导读：我尝试df.orderBy(“col1”)。show(10)，但它按升序排序。 df.sort(“col1”)。show(10)也按降序排序。我看stackoverflow和答案，我发现都是过时的或 referred to RDDs.我想使用火花的本机数据

我尝试df.orderBy(“col1”)。show(10)，但它按升序排序。 df.sort(“col1”)。show(10)也按降序排序。我看stackoverflow和答案，我发现都是过时的或 referred to RDDs.我想使用火花的本机数据帧。

我有同样的问题，和df.sort($“col1”，$“col2”.desc)没有为我工作。最后我找到了另一个解决方案：

import org.apache.spark.sql.functions._

df.orderBy(asc("col1"))

df.sort(desc("col2"))

（编辑：李大同）

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