Apache Flink：. count tWindow（）是在发生大量事件后处理代码的正确方法吗？
在Apache Flink 1.8.1上
我正在阅读https://flink.apache.org/news/2015/12/04/Introducing-windows.html，我试图弄清楚使用CountWindow（size： Int）是否适合我的用例：当N个用户访问我网站的帮助页面时，我想将他们全部标记为客户服务外展。我很困惑，因为. CountWindow（）上的留档有限，我很难确认它是否已被弃用以支持另一种方法。
然后找到留档是如此有限。充其量，我发现它列在1.3文档中，但我的IDE并没有表明它已被弃用。还有这个，看起来不相关：https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/java/org/apache/flink/table/runtime/operators/window/CountWindow.html
我是不是下错了兔子洞，还是有更好的方法来处理我上面的特殊边缘案例？
共有1个答案
它没有被弃用，您发布的是一个可以在Table API中使用的运算符，因此它没有直接连接到您根据代码使用的Streaming API。
粘贴的代码显示了coun windowing的正确用法。
至于使用Count窗口是否是一个好主意的问题，这取决于。
从技术上讲，这应该可以工作，但如果您有许多用户只访问一个页面，那么这将创建许多未关闭的窗口，因此您应该自己照顾好这一点。
通常，通过使用KeyedProcessFunction和ValueState来保持访问次数，应该更容易做到这一点。
-
具有事件源的CQR看起来非常适合作为我们的一个系统的架构，目前我们只担心一件小事：处理大量事件，并因此处理大型事件商店。 我们当前的系统每天接收大约一百万个事件（目前与事件源无关），如果我们将它们存储在更长的时间内，我们的事件存储可能会变得相当大，但是如果我们经常转储/清除滚动快照，我们可能会失去事件源的一大优势：关于系统历史和重播的信息。 在CQRS架构中处理这个问题的常见方法是什么？这到底是个
-
什么事件名称谷歌地图触摸初始化标记，出现标题或描述？google.maps.event.add监听器（标记，触摸启动，
-
问题内容： 我现在正在做一些React，我想知道是否有一种“正确的”方式来进行条件样式设计。在本教程中，他们使用 我不想使用内联样式，因此我想使用一个类来控制条件样式。一个人将如何以React的思维方式来实现这一目标？还是应该只使用这种内联样式方式？ 问题答案： 如果您更喜欢使用类名，请务必使用类名。 您可能还会发现类名称包很有用。有了它，您的代码将如下所示： 没有“正确”的方法来进行条件样式设计
-
我在Java和C#等OOP语言方面非常有经验。直到现在，我才开始与FX打交道，并开始在办公室无聊地处理事件。 我的外汇申请都是在一个类中编写的。我导入了我想要的软件包，包括以下两个： 我在主类声明中实现了类型为ActionEvent的EventHandler接口，如下所示。。 我在按钮对象上编写了一个匿名内部类来处理这样的单击事件。 它显然像它应该的那样工作，但后来我进行了一个实验。我从上面删除了
-
问题内容： 我使用10gen的本机node.js驱动器将mongodb（2.2.2）与node.js一起使用。 起初一切顺利。但是当涉及到并发基准测试部分时，会发生很多错误。频繁进行1000次并发连接/关闭可能会导致mongodb拒绝任何进一步的请求，并出现以下错误： 另外，如果许多客户端在没有显式关闭的情况下关闭，则mongodb将花费几分钟的时间来检测并关闭它们。这也将导致类似的连接问题。（使
-
我试试看。js与mongodb（2.2.2）一起使用本机节点。js drive by 10gen。 起初一切都很顺利。但在并发基准测试部分，出现了很多错误。频繁连接/关闭1000次并发可能会导致mongodb拒绝任何进一步的请求，错误如下： 此外，如果很多客户端在没有显式关闭的情况下关闭，mongodb需要几分钟来检测并关闭它们。这也会导致类似的连接问题。（使用/var/log/mongodb/m