這篇文章主要為大家展示了“Flink Watermark在任務(wù)之間如何進(jìn)行傳遞”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Flink Watermark在任務(wù)之間如何進(jìn)行傳遞”這篇文章吧。

創(chuàng)新互聯(lián)公司提供成都做網(wǎng)站、網(wǎng)站設(shè)計、網(wǎng)頁設(shè)計，成都品牌網(wǎng)站建設(shè)，廣告投放平臺等致力于企業(yè)網(wǎng)站建設(shè)與公司網(wǎng)站制作，十余年的網(wǎng)站開發(fā)和建站經(jīng)驗,助力企業(yè)信息化建設(shè)，成功案例突破成百上千家,是您實現(xiàn)網(wǎng)站建設(shè)的好選擇.

watermark本質(zhì)上就是數(shù)據(jù)流中根據(jù)記錄中的時間戳生成的一種特殊數(shù)據(jù)，是單調(diào)遞增的。在上下游中的傳遞過程如下：

1. 對于上游中的每個并行子任務(wù)，每個并行度中的watermark都會以廣播的形式發(fā)送給下游的所有并行度。注意watermark作為一種特殊的記錄，是沒有key的，只能廣播給下游所有子任務(wù)。

2. 下游接收到上游所有子任務(wù)發(fā)送過來的watermark后，選擇最小的作為本并行任務(wù)的watermark，并將其廣播給下游。

以上是“Flink Watermark在任務(wù)之間如何進(jìn)行傳遞”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前題目：FlinkWatermark在任務(wù)之間如何進(jìn)行傳遞
網(wǎng)站網(wǎng)址：http://chinadenli.net/article16/gjegdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App開發(fā)、網(wǎng)站導(dǎo)航、虛擬主機(jī)、網(wǎng)站設(shè)計、動態(tài)網(wǎng)站、面包屑導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)