WordCount是什么？WordCount編程實現(xiàn)思路

WordCount算是大數(shù)據(jù)計算領(lǐng)域經(jīng)典的入門案例，相當于Hello World。

雖然WordCount業(yè)務(wù)極其簡單，但是希望能夠通過案例感受背后MapReduce的執(zhí)行流程和默認的行為機制，這才是關(guān)鍵。

WordCount編程實現(xiàn)思路

map階段的核心：把輸入的數(shù)據(jù)經(jīng)過切割，全部標記1，因此輸出就是<單詞，1>。

shuffle階段核心：經(jīng)過MR程序內(nèi)部自帶默認的排序分組等功能，把key相同的單詞會作為一組數(shù)據(jù)構(gòu)成新的kv對。

reduce階段核心：處理shuffle完的一組數(shù)據(jù)，該組數(shù)據(jù)就是該單詞所有的鍵值對。對所有的1進行累加求和，就是單詞的總次數(shù)。

上傳課程資料中的文本文件1.txt到HDFS文件系統(tǒng)的/input目錄下，如果沒有這個目錄，使用shell創(chuàng)建。

  ?hadoop fs -mkdir /input

  ?hadoop fs -put 1.txt /input

準備好之后，執(zhí)行官方MapReduce實例，對上述文件進行單詞次數(shù)統(tǒng)計。

   第一個參數(shù)：wordcount表示執(zhí)行單詞統(tǒng)計任務(wù);

   第二個參數(shù)：指定輸入文件的路徑;

   第三個參數(shù)：指定輸出結(jié)果的路徑(該路徑不能已存在);