spark的join操作

當(dāng)我們?cè)诓僮鞅磉M(jìn)行join時(shí),如何盡可能的避免shuffle過程升敲?
(1)設(shè)置分?jǐn)?shù)函數(shù)和分?jǐn)?shù)數(shù)一樣

兩個(gè)RDD進(jìn)行join操作前,對(duì)其分別執(zhí)行了paritionBy 算子操作,并執(zhí)行力分區(qū)函數(shù)和分區(qū)數(shù):分區(qū)函數(shù)使用了HashPartition绒净,分區(qū)數(shù)分別為1和2催训。


分區(qū)函數(shù)一樣洽议、分區(qū)數(shù)不一樣

上圖中可以看到,兩個(gè)RDD發(fā)生join 是個(gè)寬依賴漫拭,是發(fā)生shuffle了的绞铃;那如何避免shuffle呢?
讓join操作變成窄依賴便不會(huì)產(chǎn)生shuffle了嫂侍,需要讓兩個(gè)RDD的分區(qū)函數(shù)和分區(qū)一樣即刻實(shí)現(xiàn)窄依賴的效果〖晕耄看下圖就可以簡單了解到挑宠。


分區(qū)函數(shù)、分區(qū)數(shù)一樣
(2)使用map-side join 替換掉join

這個(gè)場景有點(diǎn)局限了颓影,其中一個(gè)表不能過大各淀,因?yàn)樾枰M(jìn)行廣播,如果太大诡挂,那么廣播到executor端碎浇,會(huì)占用的內(nèi)存過大。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末璃俗,一起剝皮案震驚了整個(gè)濱河市奴璃,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌城豁,老刑警劉巖苟穆,帶你破解...
    沈念sama閱讀 221,273評(píng)論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異唱星,居然都是意外死亡雳旅,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,349評(píng)論 3 398
  • 文/潘曉璐 我一進(jìn)店門间聊,熙熙樓的掌柜王于貴愁眉苦臉地迎上來攒盈,“玉大人,你說我怎么就攤上這事哎榴⌒突恚” “怎么了?”我有些...
    開封第一講書人閱讀 167,709評(píng)論 0 360
  • 文/不壞的土叔 我叫張陵叹话,是天一觀的道長偷遗。 經(jīng)常有香客問我,道長驼壶,這世上最難降的妖魔是什么氏豌? 我笑而不...
    開封第一講書人閱讀 59,520評(píng)論 1 296
  • 正文 為了忘掉前任,我火速辦了婚禮热凹,結(jié)果婚禮上泵喘,老公的妹妹穿的比我還像新娘泪电。我一直安慰自己,他們只是感情好纪铺,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,515評(píng)論 6 397
  • 文/花漫 我一把揭開白布相速。 她就那樣靜靜地躺著,像睡著了一般鲜锚。 火紅的嫁衣襯著肌膚如雪突诬。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,158評(píng)論 1 308
  • 那天芜繁,我揣著相機(jī)與錄音旺隙,去河邊找鬼。 笑死骏令,一個(gè)胖子當(dāng)著我的面吹牛蔬捷,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播榔袋,決...
    沈念sama閱讀 40,755評(píng)論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼周拐,長吁一口氣:“原來是場噩夢(mèng)啊……” “哼!你這毒婦竟也來了凰兑?” 一聲冷哼從身側(cè)響起妥粟,我...
    開封第一講書人閱讀 39,660評(píng)論 0 276
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎聪黎,沒想到半個(gè)月后罕容,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,203評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡稿饰,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,287評(píng)論 3 340
  • 正文 我和宋清朗相戀三年锦秒,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片喉镰。...
    茶點(diǎn)故事閱讀 40,427評(píng)論 1 352
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡旅择,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出侣姆,到底是詐尸還是另有隱情生真,我是刑警寧澤,帶...
    沈念sama閱讀 36,122評(píng)論 5 349
  • 正文 年R本政府宣布捺宗,位于F島的核電站柱蟀,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏蚜厉。R本人自食惡果不足惜长已,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,801評(píng)論 3 333
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧术瓮,春花似錦康聂、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,272評(píng)論 0 23
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至辜伟,卻和暖如春氓侧,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背导狡。 一陣腳步聲響...
    開封第一講書人閱讀 33,393評(píng)論 1 272
  • 我被黑心中介騙來泰國打工甘苍, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人烘豌。 一個(gè)月前我還...
    沈念sama閱讀 48,808評(píng)論 3 376
  • 正文 我出身青樓,卻偏偏與公主長得像看彼,于是被迫代替她去往敵國和親廊佩。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,440評(píng)論 2 359

推薦閱讀更多精彩內(nèi)容

  • Apache Spark 是專為大規(guī)模數(shù)據(jù)處理而設(shè)計(jì)的快速通用的計(jì)算引擎靖榕。Spark是UC Berkeley AM...
    大佛愛讀書閱讀 2,834評(píng)論 0 20
  • 1.1标锄、 分配更多資源 1.1.1、分配哪些資源茁计? Executor的數(shù)量 每個(gè)Executor所能分配的CPU數(shù)...
    miss幸運(yùn)閱讀 3,186評(píng)論 3 15
  • 前言 繼基礎(chǔ)篇講解了每個(gè)Spark開發(fā)人員都必須熟知的開發(fā)調(diào)優(yōu)與資源調(diào)優(yōu)之后料皇,本文作為《Spark性能優(yōu)化指南》的...
    Alukar閱讀 881評(píng)論 0 2
  • spark-submit的時(shí)候如何引入外部jar包 在通過spark-submit提交任務(wù)時(shí),可以通過添加配置參數(shù)...
    博弈史密斯閱讀 2,750評(píng)論 1 14
  • 看著路旁的樹木上綴滿了綠色的葉子星压,隨風(fēng)搖曳践剂,有種溫柔的感覺,生命在活著里才會(huì)美好著娜膘,一懷溫暖逊脯,剎那在心間暈開。 歲...
    田萍閱讀 317評(píng)論 0 2