We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 490e338 commit 856d98eCopy full SHA for 856d98e
1 file changed
streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala
@@ -55,5 +55,6 @@ class PythonDStream[T: ClassTag](
55
case None => None
56
}
57
58
+
59
val asJavaDStream = JavaDStream.fromDStream(this)
60
0 commit comments