首页 文章

将DStream转换为JavaDStream

提问于
浏览 次
2

我知道我们有 RDD 的选项：

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

是否可以将Dstream转换为JavaDStream？

java apache-spark spark-streaming

1 回答

  • 2

    是的，你可以使用静态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))
    回复于

相关问题