单词计数 (Map Reduce版本)

yingl · yingl · commit 122b2b887335 · 2016-09-23T14:38:43.000+08:00
diff --git a/word_count_map_reduce.py b/word_count_map_reduce.py
@@ -0,0 +1,17 @@
+class WordCount:
+
+    # @param {str} line a text, for example "Bye Bye see you next"
+    def mapper(self, _, line):
+        # Write your code here
+        # Please use 'yield key, value'
+        words = line.split()
+        for word in words:
+            yield word, 1
+
+
+    # @param key is from mapper
+    # @param values is a set of value with the same key
+    def reducer(self, key, values):
+        # Write your code here
+        # Please use 'yield key, value'
+        yield key, len(values)
