我正在 Apache Flink 中编写数据流处理代码,但在 Apache Flink 文档中找不到任何提及基于计数的窗口的内容。
我检查了下面的链接,但看起来只有基于时间的窗口。 https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/operators/windows/
我认为它存在。对于键控流至少有
.countWindow()
,对于非键控流至少有 .countWindowAll()
。 Flink 开发人员提供了一个示例 WindowWordCount。
我自己从未使用过它,但我希望这是您正在寻找的。