Open kalyanhadooptraining opened 7 years ago
Location of input will be : https://github.com/KalyanHadoopProjects/project-batch1-kalyan/tree/master/kalyan/mr
Expected out details required
I tried on MapReduceTask_1 Partition the given data based on Country and Status
I was able to split the lines by using "\|" (pipeline) String[] words = line.split("\|"); when I tried to write data to context; I faced ArrayIndexOutofBoundsException String country = words[2]; String status = words[3]; context.write(new Text(country), new Text(status));
what is the expected output for map reduce task 1 ? please share your inputs.