问Apache :在并行任务之间对齐水印

EN

@Til Rohrmann的评论已经回答了这一点，主要答复是：

如果您想要查找三个发送者是相同的人，那么您应该keyBy的人，然后简单地使用一个计数窗口来生成警报。也许你也想为同一个人过滤出重复的发件人。

后续问题：

但我们也需要考虑活动时间。例如，10分钟内发送3台(事件时间不包括处理时间)

后续答复：

然后，您可以使用带有自定义触发器的事件时窗口，该触发器在看到3个元素时触发。

我想关键的结论是:如果您想要触发某项内容，请keyBy该字段。