I am working on project that schedules data local reduce tasks. However , i
wanted to know if there is a way using MapTask.java to keep track of the
inputs and size of the input to every reducer. In other words what code do
i add to get the size of the intermediate output that is fed to a reduce
task before a reduce task begins.
Thank you in advance.