我是指这个问题打两次电话给mapreduce
解决方法是调用mapreduce两次。第一个mapreduce计算每个单词的计数,然后在第二个mapreduce中计算每个计数的频率。我的问题是如何链接这两个mapreduce,即如何将第一个reduce的输出传递给第二个mapper的输入(这是一个自动解析器吗)?
Configuration conf = new Configuration();
Job job = Job.getInstance(conf, "Example");
job.setMapperClass(Mapper1.class);
job.setCombinerClass(Reducer1.class);
job.setReducerClass(Reducer1.class);
job.setMapperClass(Mapper2.class);
job.setCombinerClass(Reducer2.class);
job.setReducerClass(Reducer2.class);
暂无答案!
目前还没有任何答案,快来回答吧!