Flink：使用消息中包含的EventTime窗口的时间戳

Question

我正在将来自Kafka流光标的消息带入Flink。该消息包含Record_time字段，我想根据Record_time应用时间窗口。

我可以提取或使用Record_time字段为该邮件分配时间戳吗？由于接口TimestampExtractor的所有方法都被弃用，有没有其他的方法可以做到这一点？

Answer 1

TimestampExtractor已弃用，由AssignerWithPeriodicWatermarks和AssignerWithPunctuatedWatermarks替代。

AssignerWithPeriodicWatermarks为每条记录提取时间戳，并定期查询当前水印。

'AssignerWithPunctuatedWatermarks`也提取每个记录的时间戳。另外还要求每个记录提取一个水印。如果水印以特殊记录编码，这将很有帮助。