时间戳的链接窗口

Question

我有数据流就像

事件名，事件id，Start_time（时间戳）...

在这里，我想对最后一个带有时间戳的字段<；code>；Start_。

因此，我在flink window中看到的是.timeWindow（Time.minutes（30）），所以我猜它需要过去30分钟的事件，但不考虑开始时间

我想把数据放在start_ time在最后30分钟内的位置，然后我如何编写转换？我是否需要使用该列使用过滤器？

我是Flink的新手。

谢啦

Answer 1

你必须做两件事：

1. 通过在 StreamExecutionEnvironment 上调用 setStreamTimeCharacteristic（TimeCharacteristic.EventTime）来启用事件时间处理。
2. 为记录和水印分配时间戳。这是通过使用 AssignerWithPeriodicWatermarks 或 AssignerWithPunctuatedWatermarks 通过调用 'DataStream.assignTimestamps（yourAssigner） 来完成的。

在事件-时间模式下，Flink将根据您分配给记录的时间戳构建窗口。水印告诉Flink“你的数据的逻辑时间”。水印1000意味着不会再有时间戳小于1000的记录。

事件时处理的整个主题太复杂了，无法在这里讨论。我建议看看Apache Flink文档。