Question : Suppose we have a MapReduce job, which needs two Mappers MapperA , MapperB and then one Reducer after that also it required two more mappers MapperC and MapperD . Below is the code snippet of chaining entire flow.
JobConf conf = new JobConf(true); JobConf confA = new JobConf(false);
JobConf confB = new JobConf(false); JobConf reduceConf = new JobConf(false); JobConf confC = new JobConf(false); JobConf confD = new JobConf(false);