?

• 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(转载)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。