added reducedByKey not working yet

manishamde · Aug 18, 2014 · d25d5cf · d25d5cf
1 parent 7f7c5d1
commit d25d5cf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
@@ -58,3 +58,4 @@ class PythonDStream[T: ClassTag](
 
   val asJavaDStream  = JavaDStream.fromDStream(this)
 }
+