這篇文章主要為大家展示了“Flink Watermark在任務之間如何進行傳遞”,內容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領大家一起研究并學習一下“Flink Watermark在任務之間如何進行傳遞”這篇文章吧。
創新互聯公司提供成都做網站、網站設計、網頁設計,成都品牌網站建設,廣告投放平臺等致力于企業網站建設與公司網站制作,十余年的網站開發和建站經驗,助力企業信息化建設,成功案例突破成百上千家,是您實現網站建設的好選擇.
watermark本質上就是數據流中根據記錄中的時間戳生成的一種特殊數據,是單調遞增的。在上下游中的傳遞過程如下:
對于上游中的每個并行子任務,每個并行度中的watermark都會以廣播的形式發送給下游的所有并行度。注意watermark作為一種特殊的記錄,是沒有key的,只能廣播給下游所有子任務。
下游接收到上游所有子任務發送過來的watermark后,選擇最小的作為本并行任務的watermark,并將其廣播給下游。
以上是“Flink Watermark在任務之間如何進行傳遞”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注創新互聯行業資訊頻道!
當前題目:FlinkWatermark在任務之間如何進行傳遞
網站網址:http://vcdvsql.cn/article16/gjegdg.html
成都網站建設公司_創新互聯,為您提供App開發、網站導航、虛擬主機、網站設計、動態網站、面包屑導航
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯