我正在使用Flink SQL来处理批处理情况。如何使用FLINK SQL获取每个组的top-n记录?
发布于 2019-02-03 16:22:42
Flink SQL (直到1.7版)不提供top-n的built-in aggregation function。
您可以实现user-defined aggregation function来支持您的用例。
https://stackoverflow.com/questions/54473952
相似问题