已閱讀5頁，還剩6頁未讀， 繼續(xù)免費閱讀
版權(quán)說明：本文檔由用戶提供并上傳，收益歸屬內(nèi)容提供方，若內(nèi)容存在侵權(quán)，請進(jìn)行舉報或認(rèn)領(lǐng)
文檔簡介
cogroup算子和countByKey算子cogroup算子countByKey算子cogroup算子
cogroup這個算子使用的頻率很低，它是根據(jù)兩個RDD的key進(jìn)行關(guān)聯(lián)。具體看下面的代碼，先看下面的2個RDD。cogroup算子
上面的RDD中，words1RDD和words2RDD中的key都有重復(fù)的。然后看看用cogroup的操作結(jié)果。cogroup算子/02countByKey算子countByKey算子Spark的一個行動算子：countByKey。先去API中看一下：此算子的作用是計算每一個key的元素個數(shù)，并且把結(jié)果保存到一個Map中。countByKey算子輸出結(jié)果：countByKey算子
countByKey的源碼：就是先把rdd的value都變成1，然后reduceByKey，在通過collect行動算子拉取到driver，最后toMap轉(zhuǎn)換成一個Map類型。補充說明1.cogroup算子
2.countByKey算子
溫馨提示
- 1. 本站所有資源如無特殊說明，都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
- 2. 本站的文檔不包含任何第三方提供的附件圖紙等，如果需要附件，請聯(lián)系上傳者。文件的所有權(quán)益歸上傳用戶所有。
- 3. 本站RAR壓縮包中若帶圖紙，網(wǎng)頁內(nèi)容里面會有圖紙預(yù)覽，若沒有圖紙預(yù)覽就沒有圖紙。
- 4. 未經(jīng)權(quán)益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
- 5. 人人文庫網(wǎng)僅提供信息存儲空間，僅對用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理，對用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯，并不能對任何下載內(nèi)容負(fù)責(zé)。
- 6. 下載文件中如有侵權(quán)或不適當(dāng)內(nèi)容，請與我們聯(lián)系，我們立即糾正。
- 7. 本站不保證下載資源的準(zhǔn)確性、安全性和完整性, 同時也不承擔(dān)用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。
最新文檔
- 2025年企業(yè)聯(lián)盟運營管理協(xié)議
- 2025年藥物載體材料項目提案報告范文
- 2025年高阻隔性封裝材料項目提案報告
- 2025年生鮮電商項目規(guī)劃申請報告模板
- 2025年停車服務(wù)授權(quán)協(xié)議范本
- 2025年合作招商協(xié)議范例
- 2025年投資策劃合作協(xié)議書樣本
- 2025年醫(yī)療美容服務(wù)合同范本
- 2025年體育館施工協(xié)作協(xié)議
- 2025年住宅區(qū)綠化工程合同協(xié)議書
- 典雅中國風(fēng)詩詞大會古風(fēng)PPT模板
- DB11∕T 1653-2019 供暖系統(tǒng)能耗指標(biāo)體系
- 齒輪箱振動信號和故障診斷
- 小學(xué)生急救常識（課件）主題教育班會
- 信息光學(xué)試卷試題及答案
- 文化差異及跨文化交際試題集
- PC-Ф800×800錘式破碎機(jī)結(jié)構(gòu)設(shè)計
- 慢病患者隨訪服務(wù)記錄表
- 雙溪課程評量表完整優(yōu)秀版
- 企業(yè)名字的81種數(shù)理含義
- 最新社工服務(wù)部組織架構(gòu)
評論
0/150
提交評論