java - 将DStream转换为JavaDStream

我知道我们可以为RDD选择：

JavaRDD<String> javaRDD = coreRdd.toJavaRDD();`

是否可以将Dstream转换为JavaDStream？

最佳答案

是的，您可以使用静态JavaDStream<T>.fromDStream：

JavaDStream<String> javaDStream =
   JavaDStream$.MODULE$.fromDStream(dStream,
                                    scala.reflect.ClassTag$.MODULE$.apply(String.class))

另一种选择是使用类构造函数，该构造函数采用现有的DStream：

JavaDStream<String> javaDStream =
   new JavaDStream<String>(dStream, scala.reflect.ClassTag$.MODULE$.apply(String.class))