调用mapreduce两次

ffscu2ro  于 2021-05-27  发布在  Hadoop
关注(0)|答案(0)|浏览(255)

我是指这个问题打两次电话给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);

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题