MapReduce рекурсивная операция - PullRequest
0 голосов
/ 29 июня 2018

У меня есть базовая таблица hbase A, из которой я вызываю классы Mapper и Reducer. Результат, который я получаю, таблица A-сначала, я должен снова вызвать те же Mapper и Reducer. Можно ли вообще это сделать? Я должен выполнить рекурсию 3 раза, так как таблица A очень велика, и мой MapReduce работает для агрегирования таблицы 3 способами по отметкам времени.

И возможно ли это сделать, не создавая сначала первую таблицу A, т. Е. Отправить данные, полученные из Reducer, обратно в Mapper (таблица создана, но MapReduce выполняется для данных после редуктора, а не для доступа к таблице A в первую очередь)?

...