flink如何处理早期事件？忽略还是创建单独的窗口？
水印和后期事件的处理很容易理解，但是早期事件如何呢？例如，如果原始流包含发生在3:00到4:00的事件，但如果我将发生在6:00到7:00的事件插入到流中，那么flink如何处理这些事件？它会为它们创建单独的窗口，当窗口过期时，它们也会被处理？
共有1个答案
根据水印策略，早期事件可以提前水印，然后导致后续的“准时”事件被认为是迟到的。
-
我想制作一个JavaFX应用程序，它基本上用对象覆盖整个用户屏幕，因此基本上我可以在用户屏幕上绘制任何东西。 制作一个覆盖整个屏幕的窗口很简单。使其本质上透明可以通过本教程实现：https://assylias.wordpress.com/2013/12/08/383/ 所以唯一阻止我的是这样一个事实，尽管窗口是透明的，但它仍然会捕获用户的鼠标和按键事件。 有什么办法可以做到这一点吗？举一个更具体
-
我有一个用例，需要以不同的方式处理延迟事件和正常事件：如果事件在其窗口关闭后到达，则应将其发送到另一个路径。 我想是这样的。sideOutputLateData（..） 可以帮我解决这个问题。在正常情况下（即使用真实世界的数据）也是如此。但如果我想用伪造的数据来测试它，它就会停止工作。 我希望类似于： 将导致： 相反，我得到了： 如果我使用socketTextStream作为具有相同数据的源，它将
-
我们正在努力计算 1 分钟翻滚时间窗口内不同类型的事件的最大并发计数。 这些事件就像传感器数据，这些数据是从我们的桌面代理每分钟收集的，然而，一些代理得到了一个错误的时间戳，比如说，它甚至比现在晚了几个小时。 所以，我的问题是如何处理/删除这些事件，目前我只是应用过滤器（s = 我的第一个问题是，如果我不这样做，我怀疑这个坏的“未来”事件会触发窗口计算，即使是那些不完整的数据窗口 第二个问题是，我
-
我有一个flink cep代码，可以从套接字读取数据并检测模式。假设模式（单词）为“警报”。如果单词alert出现五次或五次以上，则应创建一个警报。但我得到了一个输入不匹配错误。Flink版本为1.3.0。提前谢谢！！
-
窗口正在进行无限循环或其他操作，我正在处理后打印数据流，但看起来根本没有达到那个点。 下面是我的伪代码。 我在reduce函数中添加了要打印的日志。正在从reduce函数打印日志。但是这条流没有被打印出来。 并且流源数据是历史数据，即。。超过2个月的旧数据。如果是历史数据流，还需要专门设置其他内容吗？ 任何输入都会大有裨益。。