问题描述
- Hadoop 单词统计,统计第四列数据
- 当前日志采集格式为:
abcd
bbfe
aacf
请用java写一个map/reduce程序,计算第四列每个元素出现的个数。大神们,求帮助。
解决方案
mapper:
String vStr = value.toString().split("")[3];
ctx.write(new Text(vStr)new IntWriteble(1));
reducer :
for(IntWriteble v : value){
ctx.write(keyv);
}
时间: 2024-11-27 23:02:26