0

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

4

1 回答 1

0

Flink SQL(直到 1.7 版本)不提供内置的top-n 聚合函数。

您可以实现用户定义的聚合函数来支持您的用例。

于 2019-02-03T08:22:41.817 回答