flink1.12.x Watermark:创建水位线的步骤4-实现 SerializableTimestampAssigner 接口

第四步

实现 SerializableTimestampAssigner 接口,该接口 提取 数据中的时间,需要实现下面方法:

long extractTimestamp(T element, long recordTimestamp);

形参:

  • T element:数据,从数据中提取出时间戳,并返回

原文出处:https://malaoshi.top/show_1IX4Rx3F8MGZ.html