Flink 的時間語義與Wartermark

1.Flink中的時間語義     在Flink的流式處理中,會涉及到時間的不同概念,如下圖所示:     Event Time:是事件創建的時間。它通常由事件中的時間戳描述,例如採集的日誌數據中,每一條日誌都會記錄自己的生成時間,Flink通過時間戳分配器訪問事件時間戳。     Ingestion Time:是數據進入Flink的時間。     Processing Time:是每一個執行基於
相關文章
相關標籤/搜索