从 DataSource 获取后，我需要过滤很多有界数据（例如，由于复杂的过滤逻辑，我无法使用查询立即过滤它）。而且我需要限制管道末端的最大数据量（以实现某种分页）。
Stream.limit()因此，在积累了所需的数据量后，我需要某种 Java来停止从 DataSource 获取行。
在 Apache Flink 中这样做的最佳方法是什么？我在看柜台，但也许有更合适的 API？
问问题
163 次
从 DataSource 获取后，我需要过滤很多有界数据（例如，由于复杂的过滤逻辑，我无法使用查询立即过滤它）。而且我需要限制管道末端的最大数据量（以实现某种分页）。
Stream.limit()因此，在积累了所需的数据量后，我需要某种 Java来停止从 DataSource 获取行。
在 Apache Flink 中这样做的最佳方法是什么？我在看柜台，但也许有更合适的 API？