df.select('orderid','roomid','probability')
probability是一个DenseVector
按orderid分组后选取probability[0]值最小的行
如何做到啊?
df.select('orderid','roomid','probability')
probability是一个DenseVector
按orderid分组后选取probability[0]值最小的行
如何做到啊?
2 回答5.1k 阅读✓ 已解决
2 回答1.1k 阅读✓ 已解决
4 回答965 阅读✓ 已解决
3 回答1.1k 阅读✓ 已解决
3 回答1.2k 阅读✓ 已解决
1 回答1.7k 阅读✓ 已解决
1 回答1.2k 阅读✓ 已解决
df.registerTempTable("df")
spark.sql("select * from df where probability in (select min(probability) from df group by orderid")