mapreduce实现计数时未执行reduce方法(未实现统计功能)
生活随笔
收集整理的這篇文章主要介紹了
mapreduce实现计数时未执行reduce方法(未实现统计功能)
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
今天寫了一個mpareduce的計數例子(統計每個單詞出現的個數),哪知沒有實現統計功能!糾結了半天才發現原來是reduce函數中的Context前面有一串包名,把它去掉后再重新執行就OK了。。。
protected void reduce(Text key, Iterable<LongWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context context)
去除包名前:
去除報名后:
總結
以上是生活随笔為你收集整理的mapreduce实现计数时未执行reduce方法(未实现统计功能)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: org.apache.hadoop.hd
- 下一篇: 《流浪地球2》大卖!刘慈欣10年言论又火