我要把Kafka的信号带到Flink。这条消息 Record_time 字段，我想根据 Record_time .我可以提取或使用 Record_time 为该消息分配时间戳的字段？作为接口的所有方法 TimestampExtractor 不赞成，还有其他方法吗？
Record_time
TimestampExtractor
i34xakig1#
TimestampExtractor 已被弃用并替换为 AssignerWithPeriodicWatermarks 以及 AssignerWithPunctuatedWatermarks . AssignerWithPeriodicWatermarks 提取每个记录的时间戳，并定期查询当前水印。´assignerWithSpuncedWatermarks`也为每条记录提取时间戳。此外，它被调用为每个记录提取一个水印。如果在特殊记录中对水印进行编码，这将非常有用。
AssignerWithPeriodicWatermarks
AssignerWithPunctuatedWatermarks
1条答案
按热度按时间i34xakig1#
TimestampExtractor已被弃用并替换为AssignerWithPeriodicWatermarks以及AssignerWithPunctuatedWatermarks.AssignerWithPeriodicWatermarks提取每个记录的时间戳，并定期查询当前水印。´assignerWithSpuncedWatermarks`也为每条记录提取时间戳。此外，它被调用为每个记录提取一个水印。如果在特殊记录中对水印进行编码，这将非常有用。