8. FlinkSQL 聚合查询 8.3. TopN 8.3.1. 普通TopN 8.3.2. 窗口Top N

在 FlinkSQL 中可以使用 TopN 实现对数据流中某个字段的排序并取出前 N 个数据。TopN 算子适用于一些需要对数据进行排序、筛选的场景，比如热门商品排行、用户行为分析等。

普通 TopN 是指对整个数据流进行排序，取出前 N 条数据。在 FlinkSQL 中，可以使用如下语句实现普通 TopN：

SELECT *
FROM (
  SELECT *,
         ROW_NUMBER() OVER (ORDER BY column DESC) as rownum
  FROM table
) t
WHERE rownum <= N

其中，ROW_NUMBER() OVER (ORDER BY column DESC) as rownum 表示对表中的某个字段进行降序排序，并为每一行分配一个 rownum，表示该行在排序后的位置。然后在外层 SELECT 语句中筛选出 rownum 小于等于 N 的数据即可。

窗口 TopN 是指对某个时间窗口内的数据进行排序，取出前 N 条数据。在 FlinkSQL 中，可以使用如下语句实现窗口 TopN：

SELECT *
FROM (
  SELECT *,
         ROW_NUMBER() OVER (PARTITION BY window ORDER BY column DESC) as rownum
  FROM table
  GROUP BY window, other_column
) t
WHERE rownum <= N

其中，ROW_NUMBER() OVER (PARTITION BY window ORDER BY column DESC) as rownum 表示对每个时间窗口内的数据进行排序，并为每一行分配一个 rownum，表示该行在排序后的位置。在外层 SELECT 语句中筛选出 rownum 小于等于 N 的数据即可。需要注意的是，在窗口 TopN 中，需要使用 GROUP BY 将数据按照时间窗口和其他字段进行分组，否则会出现重复数据。