Spark SQL窗口函数

  • ‘*’为表中所有列，‘rank()为窗口，是一个新列，于Mysql的使用一致’
val df = df.selectExpr("*"," rank() over(partition by 字段 order by 字段 desc) as 字段别名" )

//selectExpr之后依旧可以执行一些其他操作
val df = df.selectExpr("*"," rank() over(partition by 字段 order by 字段 desc) as 字段别名" ).where.等等
版权声明：本文为weixin_38468167原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。