Wandle DSTREAM zu JavaDStream

Question

Ich weiß, wir haben eine Option für RDD:

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

ist es möglich, DSTREAM zu JavaDStream konvertieren?

Answer 1

Ja, können Sie mit dem statischen JavaDStream<T>.fromDStream:

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

Eine andere Möglichkeit wäre es, die Klasse Konstruktor zu verwenden, die eine bestehende DStream nimmt:

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