fixed loose ends in david's contribution

klbostee · May 4, 2010 · 50ac115 · 50ac115
1 parent 0023739
commit 50ac115
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/dumbo/lib.py b/dumbo/lib.py
@@ -213,8 +213,8 @@ def __call__(self, key, values):
                 yield jk, v
 
     def secondary_blocked(self, key_body):
-        '''Defines the equality test between join keys.'''
-        return True
+        '''Determines if the secondary method should be blocked or not.'''
+        return False
 
     def primary(self, key, values):
         for value in values:
@@ -230,6 +230,6 @@ class JoinReducer(JoinCombiner):
     def __init__(self):
         self._key = None
 
-    def key_check(self, body):
-        return self._key == body
+    def secondary_blocked(self, body):
+        return self._key != body