将DStream转换为JavaDStream [英] Convert a DStream to JavaDStream

问题描述

我知道我们可以选择RDD:

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

是否可以将Dstream转换为JavaDStream?

is it possible to convert Dstream to JavaDStream?

推荐答案

是的，您可以使用静态

Yes, you can use the static JavaDStream<T>.fromDStream:

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

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

Another option would be to use the class constructor, which takes an existing DStream:

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

这篇关于将DStream转换为JavaDStream的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！