hadoop пример программы

WordCount - надём слово которое встречается максимальное число раз

Добавим в public static class IntSumReducer два дополнительных поля для хранения слова которое входит в текст максимум раз и числа вхождений:

Text max_occured_key = new Text();
int max_sum = 0;

И также переопределим родительский метод, который вызывается после того как редуктор отработал:

Subscribe to RSS - hadoop пример программы