Flink：使用消息中包含的EventTime窗口的時間戳

Question

我正在將來自Kafka流光標的消息帶入Flink。該消息包含Record_time字段，我想根據Record_time應用時間窗口。

我可以提取或使用Record_time字段爲該郵件分配時間戳嗎？由於接口TimestampExtractor的所有方法都被棄用，有沒有其他的方法可以做到這一點？

Answer 1

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

AssignerWithPeriodicWatermarks爲每條記錄提取時間戳，並定期查詢當前水印。

'AssignerWithPunctuatedWatermarks`也提取每個記錄的時間戳。另外還要求每個記錄提取一個水印。如果水印以特殊記錄編碼，這將很有幫助。