Flink ROW_NUMBER()函数怎么使用
已解决
收起
提个问题
2024-06-12 13:15:24
210
0
1
条回答
写回答
取消
提交回答
-
ROW_NUMBER()函数:
介绍:在窗口分区内根据rows的排序为每一行分配一个唯一的序列号,从一开始。ROW_NUMBER和RANK相似。ROW_NUMBER 按顺序对所有行进行编号(例如 1,2,3,4,5)
语法:ROW_NUMBER() OVER (PARTITION BY col1[, col2..]
ORDER BY timeAttributeCol [asc|desc])
参数:
ROW_NUMBER()计算行号的OVER窗口函数。行号从1开始计算。
PARTITION BY col1[, col2..]可选。指定分区的列,即去重的KEYS。
ORDER BY timeAttributeCol [asc|desc])指定排序的列,必须是一个时间属性的字段(即Proctime或Rowtime)。可以指定顺序(Keep FirstRow)或者倒序 (Keep LastRow)。
2024-06-12 13:15:25