implemented reduce and count function in Dstream

YanTangZhai · Sep 20, 2014 · 92e333e · 92e333e
1 parent 1b83354
commit 92e333e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py
@@ -56,8 +56,7 @@ def _sum(self):
         """
         Add up the elements in this DStream.
         """
-        pass
-        #return self._mapPartitions(lambda x: [sum(x)]).reduce(operator.add)
+        return self._mapPartitions(lambda x: [sum(x)]).reduce(operator.add)
 
     def print_(self, label=None):
         """