From 856d98e67b7df23f9c86da6c42795238c8dbcdc4 Mon Sep 17 00:00:00 2001 From: Ken Takagiwa Date: Wed, 16 Jul 2014 12:19:42 -0700 Subject: [PATCH] add empty line --- .../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 9d4eebaadc4c7..4c98f1c993317 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 @@ -55,5 +55,6 @@ class PythonDStream[T: ClassTag]( case None => None } } + val asJavaDStream = JavaDStream.fromDStream(this) }