import java.util.List; import java.util.Map; import mapreduce.MapReduce; /** * * @author mph */ public class WordCount { int numSplites; public WordCount(int numSplites) { this.numSplites = numSplites; } public Map run(String filename) { List text = FileParser.parse(filename); List> inputs = FileParser.split(text, numSplites); // TODO: instantiate a MapReduce object with correct input, key, value, and output types // TODO: set the mapper and reducer suppliers, and set the inputs // TODO: execute the MapReduce object and return the result throw new UnsupportedOperationException("WordCount.run() not implemented yet."); } class Mapper extends mapreduce.Mapper, String, Long> { @Override public Map compute() { // TODO: implement the Map function for word count throw new UnsupportedOperationException("WordCount map function not implemented yet."); } } class Reducer extends mapreduce.Reducer { @Override public Long compute() { // TODO: implement the Reduce function for word count throw new UnsupportedOperationException("WordCount reduce function not implemented yet."); } } }