CODEWITHSUNDEEP
javaapache-sparkspark-streaming
Balaji Reddy
Balaji Reddy

Reputation: 5710

Convert a DStream to JavaDStream

I know we have an option for RDD:

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

is it possible to convert Dstream to JavaDStream?

Upvotes: 3

Views: 934

Answers (1)

Yuval Itzchakov
Yuval Itzchakov

Reputation: 149636

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

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

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

Upvotes: 4

Related Questions