问题描述
从DataSource获得数据后，我需要过滤很多边界数据（例如，由于复杂的过滤逻辑，我无法使用查询立即对其进行过滤）。而且我需要在管道末端限制最大数据量（以实现某种分页）。
因此，我需要某种Java的Stream.limit()来在累积了所需的数据量之后停止从DataSource提取行。
在Apache Flink中做到这一点的最佳方法是什么？我在看柜台，但也许有更合适的API？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）
