共計 641 個字符,預計需要花費 2 分鐘才能閱讀完成。
這篇文章主要介紹“TextFile 分區(qū)問題怎么理解”,在日常操作中,相信很多人在 TextFile 分區(qū)問題怎么理解問題上存在疑惑,丸趣 TV 小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”TextFile 分區(qū)問題怎么理解”的疑惑有所幫助!接下來,請跟著丸趣 TV 小編一起來學習吧!
val rdd1 = sc.parallelize(List(2,3,4,1,7,5,6,9,8))
獲取分區(qū)的個數(shù):rdd1.partitions.length, 在 spark-shell 中沒有指定分區(qū)的個數(shù)獲取的是默認分區(qū)數(shù), 除了這個外 parallelize 方法可以使用, 指定幾個分區(qū)就會有幾個分區(qū)出現(xiàn)
val rdd1 = sc.textFile(hdfs://hadoop02:8020/word.txt ,3).flatMap _.split()).map((_,1)).reduceByKey(_+_)
textFile 這個方法是有默認值就是 2 除非改變 loacl 中的即默認值這個只要這個默認值小于 2 的話會使用小于默認的值
這個默認屬性是有值的 defaultMinPartitions
如果在 textfile 中傳入了分區(qū)數(shù), 那么這個分區(qū)數(shù)可能相同也可能不同需要看底層計算!
到此,關于“TextFile 分區(qū)問題怎么理解”的學習就結(jié)束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續(xù)學習更多相關知識,請繼續(xù)關注丸趣 TV 網(wǎng)站,丸趣 TV 小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p/>