Advertisement

Scala DataFrame 实现窗口排序功能;row_number();rank();dense_rank()

阅读量:

在Hive中,窗口函数的使用非常便捷,那么在DataFrame中该如何实现类似功能呢?

1、数据准备: 当前存在一张名为score的表格,其中包含如下数据,字段名称分别为:s_id,c_id,s_score,分别对应学号、课程编号和成绩。

复制代码
    hive> select * from score;
    OK
    1       1       80
    1       2       90
    1       3       99
    2       1       70
    2       2       60
    2       3       180
    3       1       80
    3       2       80
    3       3       80
    4       1       50
    4       2       30
    4       3       40
    5       1       76
    5       2       87
    6       1       31
    6       3       34
    7       2       89
    7       3       98
    
    

全部评论 (0)

还没有任何评论哟~