基于flink1.14的源码做解析 公司内有很多业务方都在使用我们Flink sql平台做TopN的计算，今天同事突然问到我，Flink sql 是怎么实现topN的 ？ 蒙圈了，这块源码没看过啊 ，业务要问起来怎么办，赶快打开源码补一下 拿到这个问题先冷静分析一下范围 首先肯定属于Flink sql模块，源码里面肯定是在flink-table-planner包里面，接着topN那不就是ROW_