当两个ID在Scala中具有最高价格时，获得最高的ID价格

Question

我有一个dataframe call productPrice具有列ID和价格，我想获得具有最高价格的ID，如果两个ID具有相同的最高价格，我只得到一个具有较小的ID号。我使用

val highestprice = productPrice.orderBy(asc("ID")).orderBy(desc("price")).limit(1)但是我得到的结果不是具有较小ID的结果，而是我得到的是具有较大ID的ID。我不知道我的逻辑有什么问题吗？

Answer 1

尝试这个。

scala> val df = Seq((4, 30),(2,50),(3,10),(5,30),(1,50),(6,25)).toDF("id","price")
df: org.apache.spark.sql.DataFrame = [id: int, price: int]
scala> df.show
+---+-----+
| id|price|
+---+-----+
|  4|   30|
|  2|   50|
|  3|   10|
|  5|   30|
|  1|   50|
|  6|   25|
+---+-----+

scala> df.sort(desc("price"), asc("id")).show
+---+-----+
| id|price|
+---+-----+
|  1|   50|
|  2|   50|
|  4|   30|
|  5|   30|
|  6|   25|
|  3|   10|
+---+-----+

Answer 2

使用Spark SQL：

解决相同的问题

val df = Seq((4, 30),(2,50),(3,10),(5,30),(1,50),(6,25)).toDF("id","price")
df.createOrReplaceTempView("prices")

-

%sql
SELECT id, price
FROM prices
ORDER BY price DESC, id ASC
LIMIT(1)