Вызовите MapReduce дважды - PullRequest
Новая
       8

Вызовите MapReduce дважды

0 голосов
/ 12 марта 2019

Я имею в виду этот вопрос Вызов MapReduce дважды

Решением будет вызов MapReduce дважды.Первый MapReduce вычисляет счетчик каждого слова, а затем во втором MapReduce вычисляется частота каждого счетчика.Мой вопрос заключается в том, как связать эти два MapReduce, т. Е. Как передать выходные данные 1-го редуктора на вход 2-го преобразователя (это автоматический анализатор)? 

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);
...