apache flink窗口顺序

Question

使用Apache Flink我想创建一个按照存储在Kafka事件中的时间戳排序的流式窗口。根据以下文章，这没有实施。

https://cwiki.apache.org/confluence/display/FLINK/Time+and+Order+in+Streams

不过，文章的日期是2015年7月，现在几乎是一年之后。是否实现了此功能，并且有人可以将我指向任何相关的文档和/或示例。

Answer 1

Apache Flink支持基于事件时间戳的流窗口。 在Flink中，这个概念被称为事件时间。

为了支持事件时间，您必须从每个事件中提取时间戳（长整型值）。另外，您需要支持所谓的水印，这些水印需要处理具有乱序时间戳的事件。

考虑到与提取的时间戳流可以如下定义窗总和：

​​

事件的时间和窗口进行了详细的文档（here和here）中，并在几个博客文章解释（here ，here，here和here）。

Answer 2

按时间戳排序仍然不支持开箱即用，但您可以根据元素中的时间戳进行开窗。我们称之为事件时间窗口。请看看这里：https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/windows.html。