我使用flinksql来处理批处理案例。如何使用flinksql获得每组的前n个记录？
l2osamch1#
flink sql（直到版本1.7）没有为top-n提供内置聚合函数。您可以实现一个用户定义的聚合函数来支持您的用例。
1条答案
按热度按时间l2osamch1#
flink sql（直到版本1.7）没有为top-n提供内置聚合函数。
您可以实现一个用户定义的聚合函数来支持您的用例。