返回信息流如题
小弟有一些小疑惑求解答
这是一条镜像帖。来源:北邮人论坛 / database / #6927同步于 2012/6/24
该镜像源已超过 30 天没有更新,可能在源站已被删除。
Database机器人发帖
请问哪位大神有在hadoop上写程序的经验?
Captain1991
2012/6/24镜像同步6 回复
订阅后,新回复会通过你的通知中心匿名送达。
6 条回复
Map类中map方法分析
public static class Map extends MapReduceBase implements
Mapper<longwritable intwritable="" text,="" ,=""> {
private final static IntWritable one = new IntWritable(1);
private Text word = new Text();
public void map(LongWritable key, Text value,
OutputCollector<text intwritable="" ,=""> output, Reporter reporter)
throws IOException {
String line = value.toString();
StringTokenizer tokenizer = new StringTokenizer(line);
while (tokenizer.hasMoreTokens()) {
word.set(tokenizer.nextToken());
output.collect(word, one);
}
}
}</text></longwritable>
Map类继承自MapReduceBase,并且它实现了Mapper接口,此接口是一个规范类型,它有4种形式的参数,分别用来指定map的输入key值类型、输入value值类型、输出key值类型和输出value值类型。在本例中,因为使用的是TextInputFormat,它的输出key值是LongWritable类型,输出value值是Text类型,所以map的输入类型为<LongWritable,Text>。在本例中需要输出<word,1>这样的形式,因此输出的key值类型是Text,输出的value值类型是IntWritable。
实现此接口类还需要实现map方法,map方法会具体负责对输入进行操作,在本例中,map方法对输入的行以空格为单位进行切分,然后使用OutputCollect收集输出的<word,1>。
问:
Map的形参写成 <longwritable intwritable="" text,="" ,=""> 这样是什么意思啊
恩 是的 明显不对
当时我刚接触这个东西 啥都不懂
在别人一篇博客里复制的
后来博主告诉我 他把代码复制到博客里 有些东西由于字符编码的问题显示错了 就形成了这样
【 在 leemashal 的大作中提到: 】
: lz哪里找的代码,明显不对啊