flink的TimeCharacteristic(转载)

 

• flink的TimeCharacteristic枚举定义了三类值，分别是ProcessingTime、IngestionTime、EventTime
• ProcessingTime是以operator处理的时间为准，它使用的是机器的系统时间来作为data stream的时间；
• IngestionTime是以数据进入flink streaming data flow的时间为准；
• EventTime是以数据自带的时间戳字段为准，应用程序需要指定如何从record中抽取时间戳字段
• 指定为EventTime的source需要自己定义event time以及emit watermark，或者在source之外通过assignTimestampsAndWatermarks在程序手工指定

 

Reference:

[1]聊聊flink的TimeCharacteristic

 

总结

以上是生活随笔为你收集整理的flink的TimeCharacteristic(转载)的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。