久久精品国产亚洲高清|精品日韩中文乱码在线|亚洲va中文字幕无码久|伊人久久综合狼伊人久久|亚洲不卡av不卡一区二区|精品久久久久久久蜜臀AV|国产精品19久久久久久不卡|国产男女猛烈视频在线观看麻豆

    1. <style id="76ofp"></style>

      <style id="76ofp"></style>
      <rt id="76ofp"></rt>
      <form id="76ofp"><optgroup id="76ofp"></optgroup></form>
      1. 千鋒教育-做有情懷、有良心、有品質(zhì)的職業(yè)教育機(jī)構(gòu)

        手機(jī)站
        千鋒教育

        千鋒學(xué)習(xí)站 | 隨時(shí)隨地免費(fèi)學(xué)

        千鋒教育

        掃一掃進(jìn)入千鋒手機(jī)站

        領(lǐng)取全套視頻
        千鋒教育

        關(guān)注千鋒學(xué)習(xí)站小程序
        隨時(shí)隨地免費(fèi)學(xué)習(xí)課程

        當(dāng)前位置:首頁  >  技術(shù)干貨  > 大數(shù)據(jù)筆試題之Spark常見的屬性區(qū)別總結(jié)

        大數(shù)據(jù)筆試題之Spark常見的屬性區(qū)別總結(jié)

        來源:千鋒教育
        發(fā)布人:小千
        時(shí)間: 2021-01-13 10:48:00 1610506080

              在進(jìn)行大數(shù)據(jù)的面試過程中,經(jīng)常會(huì)被問到一些比較相近的屬性區(qū)別是什么,提前了解一下幫助你更好的應(yīng)對(duì)面試提問。

        u=1975023593,3058096462&fm=26&gp=0

              1.repartition和coalesce的區(qū)別

              1.1. repartition只是coalesce接口中shuffle為true的實(shí)現(xiàn)

              1.2. 不經(jīng)過 shuffle,也就是coaleasce shuffle為false,是無法增加RDD的分區(qū)數(shù)的,比如你源RDD 100個(gè)分區(qū),想要變成200個(gè)分區(qū),只能使用repartition,也就是coaleasce shuffle為true。

              1.3. 如果上游為Partition個(gè)數(shù)為N,下游想要變成M個(gè)Partition

              N > M , 比如N=100 M=60, 可以使用coaleasce shuffle為false。但是如果N遠(yuǎn)大于M,比如N=100, M=1, 分區(qū)有一個(gè)激烈的變化時(shí),此時(shí)如果用coalesce就只有一個(gè)task處理數(shù)據(jù),資源利用不夠, Executor空跑,這時(shí)repartition是一個(gè)比較好的選擇,雖然有shuffle但是和只有1個(gè)Task處理任務(wù)比起來效率還是較高。

              N < M , coaleasce shuffle為false 不能增加分區(qū),只能用repartition

              2.groupByKey 和 reduceBykey 區(qū)別

              reduceByKey 可以接收一個(gè) func 函數(shù)作為參數(shù),這個(gè)函數(shù)會(huì)作用到每個(gè)分區(qū)的數(shù)據(jù)上,即分區(qū)內(nèi)部的數(shù)據(jù)先進(jìn)行一輪計(jì)算,然后才進(jìn)行 shuffle 將數(shù)據(jù)寫入下游分區(qū),再將這個(gè)函數(shù)作用到下游的分區(qū)上,這樣做的目的是減少 shuffle 的數(shù)據(jù)量,減輕負(fù)擔(dān)。

        1

              groupByKey 不接收函數(shù),Shuffle 過程所有的數(shù)據(jù)都會(huì)參加,從上游拉去全量數(shù)據(jù)根據(jù) Key 進(jìn)行分組寫入下游分區(qū),這樣會(huì)消耗比較多的資源,數(shù)據(jù)傳輸會(huì)導(dǎo)致任務(wù)處理的延遲。

        2

              如果我們想要進(jìn)行分組后進(jìn)行聚合操作,使用 reduceByKey 會(huì)更高效, 因?yàn)閞educeByKey 會(huì)在map階段合并分區(qū)內(nèi)相同的key,而gourpByKey 則不會(huì)合并。

              3.Cache,Presist,CheckPoint的區(qū)別

              Persist 的 MEMORY_ONLY 級(jí)別的存儲(chǔ)等于 Cache,Persist 其他的配置只是存儲(chǔ)的方式不同,作用和原理是和 Cache 類似的,他們二者的區(qū)別如下:

              *Cache、Persist 是轉(zhuǎn)化類算子,和其他算子一樣,觸發(fā)的時(shí)機(jī)是在對(duì)應(yīng)分區(qū)的上游算子計(jì)算完成之后。

              *Cache、Persist 會(huì)把 RDD 緩存到指定位置,這個(gè)操作不會(huì)改變 Lineage 血緣的依賴關(guān)系,且 Job 執(zhí)行完成之后,緩存的數(shù)據(jù)會(huì)被清除。

              *Cache、Persist 一般應(yīng)用于需要訪問重復(fù)數(shù)據(jù)的應(yīng)用(如迭代型算法和交互式應(yīng)用)緩存可以運(yùn)行得更快。

              *CheckPoint 執(zhí)行完畢后,會(huì)產(chǎn)生 CheckPointRDD,此時(shí) lineage 血緣關(guān)系已經(jīng)改變了,容錯(cuò)會(huì)從CheckPointRDD 開始。

              *CheckPoint 將 RDD 持久化到 HDFS ,會(huì)被永久保存,可以給其他的 Driver 使用

              *雖然Presist 也可以持久化數(shù)據(jù)到磁盤,但是它有BlockManager管理,一旦Driver結(jié)束,BlockManager也會(huì) stop,被 cache 到磁盤上的 RDD 也會(huì)被清空,而 checkpoint 將 RDD 持久化到HDFS或本地文件,如果不被手動(dòng) remove 掉,是一直存在的。

              最后歡迎大家添加我們的大數(shù)據(jù)分享交流qq群:857910996 加群找管理領(lǐng)取免費(fèi)的大數(shù)據(jù)學(xué)習(xí)資料,還可以交流學(xué)習(xí)心得,歡迎大家進(jìn)群~~~

        tags:
        聲明:本站稿件版權(quán)均屬千鋒教育所有,未經(jīng)許可不得擅自轉(zhuǎn)載。
        10年以上業(yè)內(nèi)強(qiáng)師集結(jié),手把手帶你蛻變精英
        請(qǐng)您保持通訊暢通,專屬學(xué)習(xí)老師24小時(shí)內(nèi)將與您1V1溝通
        免費(fèi)領(lǐng)取
        今日已有369人領(lǐng)取成功
        劉同學(xué) 138****2860 剛剛成功領(lǐng)取
        王同學(xué) 131****2015 剛剛成功領(lǐng)取
        張同學(xué) 133****4652 剛剛成功領(lǐng)取
        李同學(xué) 135****8607 剛剛成功領(lǐng)取
        楊同學(xué) 132****5667 剛剛成功領(lǐng)取
        岳同學(xué) 134****6652 剛剛成功領(lǐng)取
        梁同學(xué) 157****2950 剛剛成功領(lǐng)取
        劉同學(xué) 189****1015 剛剛成功領(lǐng)取
        張同學(xué) 155****4678 剛剛成功領(lǐng)取
        鄒同學(xué) 139****2907 剛剛成功領(lǐng)取
        董同學(xué) 138****2867 剛剛成功領(lǐng)取
        周同學(xué) 136****3602 剛剛成功領(lǐng)取
        相關(guān)推薦HOT
        為什么sql語句不支持關(guān)系代數(shù)中的除法?

        為什么SQL語句不支持關(guān)系代數(shù)中的除法1. SQL和關(guān)系代數(shù)的關(guān)系:SQL是一種基于關(guān)系代數(shù)的查詢語言,它的設(shè)計(jì)初衷是為了能夠以一種更接近自然語言...詳情>>

        2023-10-14 04:07:35
        sql 怎么根據(jù)父id查詢下三級(jí)子集?

        一、概述處理樹形數(shù)據(jù)時(shí),我們常常需要根據(jù)父ID查詢其下的子集。本文將引導(dǎo)您如何使用SQL進(jìn)行這一操作,尤其是查詢下三級(jí)子集。二、查詢方法詳...詳情>>

        2023-10-14 03:59:07
        什么是分治算法,和遞歸有什么關(guān)系?

        分治算法是什么分治算法是一種算法設(shè)計(jì)思想,其主要思想是將一個(gè)復(fù)雜的問題分解為兩個(gè)或更多相同或相似的子問題,直到子問題簡(jiǎn)單到可以直接解決...詳情>>

        2023-10-14 03:22:51
        為什么微服務(wù)一定要上Docker?

        為什么微服務(wù)一定要上Docker微服務(wù)作為一種軟件架構(gòu)模式,需要考慮的因素包括服務(wù)的獨(dú)立性、可擴(kuò)展性、可維護(hù)性和可移植性等。這其中,Docker的...詳情>>

        2023-10-14 03:15:33
        C++的traits技術(shù)到底是什么?

        在C++編程中,traits是一種編程技巧,其主要目的是在編譯時(shí)提供關(guān)于類型的額外信息。它可以將類型的一些特性(如其關(guān)聯(lián)類型、屬性、函數(shù)等)抽...詳情>>

        2023-10-14 03:00:03
        快速通道
        牟定县| 阿图什市| 陵水| 洛浦县| 碌曲县| 隆化县| 修文县| 调兵山市| 恩施市| 烟台市| 千阳县| 收藏| 平武县| 虞城县| 拉孜县| 绩溪县| 钟山县| 霍州市| 翁牛特旗| 阜康市| 大港区| 永和县| 华坪县| 枝江市| 常德市| 二连浩特市| 郓城县| 鲁甸县| 岗巴县| 文化| 偏关县| 牡丹江市| 永吉县| 南安市| 信丰县| 翁源县| 岱山县| 同仁县| 方城县| 尉氏县| 杂多县|