我正在使用WordCount示例,在Reduce函数中,我需要获取文件名.
public static class Reduce extends MapReduceBase implements Reducer{ public void reduce(Text key, Iterator values, OutputCollector output, Reporter reporter) throws IOException { int sum = 0; while (values.hasNext()) { sum += values.next().get(); } String filename = ((FileSplit)(.getContext()).getInputSplit()).getPath().getName(); // ----------------------------^ I need to get the context and filename! key.set(key.toString() + " (" + filename + ")"); output.collect(key, new IntWritable(sum)); } }
这是上面修改过的代码,我想要获取要为该单词打印的文件名.我尝试了遵循Java Hadoop:我如何创建作为输入文件的输出器并给出一个输出,即每个文件中的行数?但我无法得到这个context
物体.
我是hadoop的新手,需要这个帮助.有帮助吗?