Select 每组使用 Flink 的前 N ​​个 Sql

Select Top N Per Group using Flink Sql

我正在使用 Flink SQL 来处理批处理案例。 如何使用 FLINK SQL 获取每个组的前 n 条记录?

Flink SQL(直到 1.7 版)不提供 built-in aggregation function for top-n。

您可以实施 user-defined aggregation function 来支持您的用例。