将 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))

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

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

将 DStream 转换为 JavaDStream

Convert a DStream to JavaDStream

java

apache-spark

spark-streaming