如何找到最高和最低的产品价格

Posted 2023-04-15

【中文标题】如何找到最高和最低的产品价格

【英文标题】：How to find the highest and lowest product price

【发布时间】：2017-11-25 06:13:53

【问题描述】：

我是 Scala 新手并且有一个 DataFrame，我需要找到每个 category_id 的最高和最低产品价格。

数据框的前 20 行是：

请告诉我该怎么做。

【参考方案1】：

你可以使用窗口操作，那么它应该如下：

df.withColumn("rank", rank().over(Window.partitionBy("Category_id").orderBy($"price".desc)))
    .filter($"rank" <= 20)
    .drop("rank")

希望对你有帮助。

【讨论】：

您好，收到以下错误 :39: error: not found: value Window val df5 = df.withColumn("rank", rank().over(Window.partitionBy("category_id" ).orderBy($"price".desc))).filter($"rank"

你需要导入行import org.apache.spark.sql.expressions.Window

嗨 Ramesh，如何在不使用 spark SQL 的情况下做同样的事情？？

@DeepakPaul 为什么要不用 spark SQL？