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);
}
}
}
我试图理解 map-reduce 中的 map 函数的这个基本程序,输入参数是什么?我找不到地图的定义。
如果有人能告诉我这个功能在做什么,那就太好了