在从数据源获取数据之后，我需要过滤很多有界数据（比如说，由于复杂的过滤逻辑，我无法使用query立即过滤）。我需要限制管道末端的最大数据量（以实现某种分页）。
所以，我需要一些java的 Stream.limit() 在积累了所需的数据量之后，停止从数据源提取行。
在apache flink中最好的方法是什么？我在看计数器，但也许有更合适的api？