Может ли кто-нибудь помочь мне в настройке рабочего потока с помощью действия Map-Reduce, которое принимает несколько входных путей, каждый входной путь связан с одним Mapper, как, например, MultipleInputs.addInputPath api принимает входной путь и преобразователь. Выход этих картеров будет отдан редуктору.

Я пробовал это с действием Java, но он будет выполнять только одну задачу карты. Но здесь входной путь содержит огромные данные, поэтому действие java не будет в этом случае.

Есть ли способ справиться с этим делом?

С уважением, Криш.