вывод одной программы mapreduce как ввод в другую программу mapreduce
Я пытаюсь простой пример, в котором вывод одного задания MapReduce должен быть ввод другого задания MapReduce.
Поток должен быть таким:Mapper1 --> Reducer1 --> Mapper2 --> Reducer2 (Выход Mapper1 должен быть входом Reducer1. Выход Reducer1 должен быть входом Mapper2. Выход Mapper2 должен быть входом Reducer2. Выход Reducer2 должен храниться в выходном файле).
Как я могу добавить несколько Mappers и Reducers к моей программе так, чтобы поток поддерживался как выше?
Нужно ли использовать Цепные картографы или Цепные редукторы? Если да, то как я могу их использовать?