0
@@ -1,30 +1,14 @@
0
 #!/usr/bin/env python
0
 # encoding: utf-8
0
-from collections import defaultdict
0
 import unittest
0
 from helpers import test
0
+from examples.word_count import WordCountJob
0
 
0
 from hadoop import Job
0
 from hadoop.parsers import LineParser, KeyValueParser
0
 from hadoop.collectors import Collector
0
 import hadoop.runner
0
 
0
-class WordCountJob(Job):
0
-  """A sample word-count Hadoop job."""
0
-  
0
-  def map(self, line, collector):
0
-    """Splits line into words, emits counts."""
0
-    for word in line.split(' '):
0
-      collector.collect(word.strip(), 1)
0
-  
0
-  def reduce(self, iterator, collector):
0
-    """Reduces word counts, collects totals."""
0
-    accumulator = defaultdict(int)
0
-    for word, count in iterator:
0
-      accumulator[word] += int(count)
0
-    for word, total in accumulator.iteritems():
0
-      collector.collect(word, total)
0
-
0
 
0
 class MockStream(object):
0
   def __init__(self):