将DStream转换为JavaDStream

Question

我有一个函数是从scala包(DStream)调用的，我想将它转换为JavaDStream。我想知道是否有任何函数可以用来将下面的函数转换为JavaDStream，以便在我的Java应用程序中发挥作用。或者，spark提供的类似函数与scala库中的ConstantInputDStream类似吗？

//Convert DStream to a JavaDStream

  DStream refreshDstream = new  ConstantInputDStream(jssc.ssc(), emptyRDD.rdd(),scala.reflect.ClassTag$.MODULE$.AnyRef()).window(new Duration(refreshInterval));

Answer 1

选项1:使用构造器

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

选项2:使用静态方法

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

Answer 2

据我所知，JavaDStream有两个选项：

• JavaDStream.fromDStream()法
• JavaDStream构造函数

你试过那些吗？