Я очень новичок Hadoop, но в Hadoop 1.1.1 я пытаюсь сделать карту -> уменьшить -> карту -> уменьшить. Мне сложно найти конкретный пример того, как это сделать на Java. Мне действительно интересно, как выглядит весь метод драйвера. В настоящее время я использую библиотеки org.apache.hadoop.mapreduce
(что, я считаю, является самой новой базой кода).Цепочка Hadoop MapReduce 1.1.1 Пример
Кроме того, я бы предпочел не устанавливать другую библиотеку, такую как Oozie, если мне это не нужно.
Вы хотите, чтобы вы активировали mapper после функции уменьшения, а затем снова вызвали редуктор для последнего преобразователя? Если да, то почему? Чего вы пытаетесь достичь? – aa8y
@Expressions_Galore Да, я так думаю. Из того, что я читал, обычно приходится иметь дело с несколькими мапперами и редукторами, для меня просто не очевидно, как это сделать. – Newtang
Это то, чего вы пытаетесь достичь? http://stackoverflow.com/questions/11122832/hadoop-mapreduce-possible-to-define-two-mappers-and-reducers-in-one-hadoop-job – aa8y