Estoy probando un ejemplo simple, en el que la salida de un trabajo MapReduce debe ser la entrada de otro trabajo MapReduce.

El flujo debería ser así:Mapper1 --> Reducer1 --> Mapper2 --> Reducer2 (La salida de Mapper1 debe ser la entrada de Reducer1. La salida de Reducer1 debe ser la entrada de Mapper2. La salida de Mapper2 debe ser la entrada de Reducer2. La salida de Reducer2 debe almacenarse en el archivo de salida).

¿Cómo puedo agregar múltiples mapeadores y reductores a mi programa de modo que el flujo se mantenga como se indicó anteriormente?

¿Necesito usar Chain Mappers o Chain Reducers? Si es así, ¿cómo puedo usarlos?