如何找到最高和最低的产品价格
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")
希望对你有所帮助
我是 Scala 的新手并且有一个 DataFrame,我需要找到每个 category_id 的最高和最低产品价格。
数据框的前 20 行是:
请告诉我该怎么做。
你可以使用window操作,那么它应该如下:
df.withColumn("rank", rank().over(Window.partitionBy("Category_id").orderBy($"price".desc)))
.filter($"rank" <= 20)
.drop("rank")
希望对你有所帮助