轉換一個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))