Beam中的Watermark是用于確保數據的時序完整性和準確性的重要機制。Watermark是一個時間戳,用來表示數據流中的事件的最大允許延遲時間。Beam會根據Watermark來判斷哪些數據可以被處理,哪些數據已經延遲太久,需要被丟棄或者進行其他處理。通過Watermark,Beam可以在處理無界數據流時保證數據的正確性和時序性。
億速云公眾號
手機網站二維碼
Copyright ? Yisu Cloud Ltd. All Rights Reserved. 2018 版權所有
廣州億速云計算有限公司粵ICP備17096448號-1 粵公網安備 44010402001142號增值電信業務經營許可證編號:B1-20181529