mapReduce job的提交流程

舉一個非常簡單的例子,通過mapreduce計算單詞數量,下面爲相關代碼: 1)準備環境,創建一個java工程,導入相關hdfs jar包,這些so easy 不在複述。 2)首先我們都知道mapreduce框架,經過2個階段,一個map階段一個reduce階段,所以我們首先要創建一個map來整理我們的單詞和數量然後通過reduce來計算我們的單詞相關總數。相關代碼如下: 我們可以把上面工程打成j
相關文章
相關標籤/搜索