Как настроить рабочий процесс oozie для нескольких входных путей с несколькими мапперами
Может ли кто-нибудь помочь мне в настройке рабочего потока с помощью действия Map-Reduce, которое принимает несколько входных путей, каждый входной путь связан с одним Mapper, как, например, MultipleInputs.addInputPath api принимает входной путь и преобразователь. Выход этих картеров будет отдан редуктору.
Я пробовал это с действием Java, но он будет выполнять только одну задачу карты. Но здесь входной путь содержит огромные данные, поэтому действие java не будет в этом случае.
Есть ли способ справиться с этим делом?
С уважением, Криш.