Java教程

flink-- Window Top-N使用讲解及源码示例

本文主要是介绍flink-- Window Top-N使用讲解及源码示例，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

1. 什么是Window Top-N

Window Top-N是一个特殊的Top-N，它返回每个窗口和其他分区键的N个最小或最大值。

  • 对于流查询，与连续表上的常规top-N不同，窗口top -N不产生中间结果，只产生最终结果，即一个窗口中包含数据集的top -N记录。
  • Top-N窗口在不再需要时清除所有中间状态，因此如果用户不需要更新每条记录的结果，窗口Top-N查询具有更好的性能
  • 通常窗口Top-N与窗口聚合一起使用

2. window Top-N语法

Window Top-N要求PARTITION BY子句包含应用窗口TVF或窗口聚合函数产生的新关系的window_start和window_end列

SELECT [column_list]
FROM (
   SELECT [column_list],
     ROW_NUMBER()
这篇关于flink-- Window Top-N使用讲解及源码示例的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航