mapreduce实现计数时未执行reduce方法(未实现统计功能)
生活随笔
收集整理的這篇文章主要介紹了
mapreduce实现计数时未执行reduce方法(未实现统计功能)
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
今天寫了一個(gè)mpareduce的計(jì)數(shù)例子(統(tǒng)計(jì)每個(gè)單詞出現(xiàn)的個(gè)數(shù)),哪知沒有實(shí)現(xiàn)統(tǒng)計(jì)功能!糾結(jié)了半天才發(fā)現(xiàn)原來是reduce函數(shù)中的Context前面有一串包名,把它去掉后再重新執(zhí)行就OK了。。。
protected void reduce(Text key, Iterable<LongWritable> values,
org.apache.hadoop.mapreduce.Reducer.Context context)
去除包名前:
去除報(bào)名后:
總結(jié)
以上是生活随笔為你收集整理的mapreduce实现计数时未执行reduce方法(未实现统计功能)的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: org.apache.hadoop.hd
- 下一篇: mapreduce的规约(Combine