java - 将 DStream 转换为 JavaDStream

Question

我知道我们有一个 RDD 选项:

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

是否可以将 Dstream 转换为 JavaDStream？

Answer 1

是的，您可以使用静态 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))