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

How to find the highest and lowest product price

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

数据框的前 20 行是:

请告诉我该怎么做。

你可以使用window操作,那么它应该如下:

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

希望对你有所帮助