From d25d5cf9c7343dacea9511da9330d757e9cb810e Mon Sep 17 00:00:00 2001
From: Ken Takagiwa <ken@Kens-MacBook-Pro.local>
Date: Tue, 15 Jul 2014 21:08:43 -0700
Subject: [PATCH] added reducedByKey not working yet

---
 .../org/apache/spark/streaming/api/python/PythonDStream.scala    | 1 +
 1 file changed, 1 insertion(+)

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
index 76b88385e095a..c95c81d994a95 100644
--- 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)
 }
+