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。