Flink Time和Watermark的理解

Flink Time和Watermark的理解 1. Time 背景 在實際開發過程當中,咱們可能須要接入各類流數據源,好比在線業務用戶點擊流數據、監控系實時收集到的事件流數據、從傳感器採集到的實時數據,等等,爲了處理方便他們可能會寫入Kafka消息中間件集羣中某個/某些topic中,或者選擇其它的緩衝/存儲系統。這些數據源中數據元素具備固定的時間屬性,是在流數據處理系統以外的其它系統生成的。好比
相關文章
相關標籤/搜索