开发者社区> 问答> 正文

Flink ROW_NUMBER()函数怎么使用

已解决

Flink ROW_NUMBER()函数怎么使用

展开
收起
提个问题! 2024-06-12 13:15:24 184 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
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载