Flink之Watermark實踐

咱們知道實時計算中,數據時間比較敏感,有eventTime和processTime區分,通常來講eventTime是從原始的消息中提取過來的,processTime是Flink本身提供的,Flink中一個亮點就是能夠基於eventTime計算,這個功能頗有用,由於實時數據可能會通過比較長的鏈路,多少會有延時,而且有很大的不肯定性,對於一些須要精確體現事件變化趨勢的場景中,單純使用processTi
相關文章
相關標籤/搜索