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) }