Initial commit

1 files changed, 52 insertions, 0 deletions

diff --git a/WordCount.java b/WordCount.java
new file mode 100644
index 0000000..3c224d4
--- /dev/null
+++ b/WordCount.java
@@ -0,0 +1,52 @@
+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<String, Long> run(String filename) {
+    List<String> text = FileParser.parse(filename);
+    List<List<String>> 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<List<String>, String, Long> {
+
+    @Override
+    public Map<String, Long> compute() {
+      // TODO: implement the Map function for word count
+      throw new UnsupportedOperationException("WordCount map function not implemented yet.");
+    }
+
+  }
+
+  class Reducer
+      extends mapreduce.Reducer<String, Long, Long> {
+
+    @Override
+    public Long compute() {
+      // TODO: implement the Reduce function for word count
+      throw new UnsupportedOperationException("WordCount reduce function not implemented yet.");
+    }
+  }
+
+}