added reducedByKey not working yet

Ken Takagiwa · giwa · commit d25d5cf9c734 · 2014-08-18T15:27:38.000-07:00
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)
 }
+

Original file line number	Diff line number	Diff line change
`@@ -58,3 +58,4 @@ class PythonDStream[T: ClassTag](`
`58`	`58`
`59`	`59`	`val asJavaDStream = JavaDStream.fromDStream(this)`
`60`	`60`	`}`
	`61`	`+`