将 DStream 转换为 JavaDStream

Question

我有一个从 scala 包 (DStream) 调用的函数，我想将其转换为 JavaDStream。我想知道是否有任何函数可以用来将下面的函数转换为 JavaDStream，以便在我的 Java 应用程序中利用。或者spark在scala api library for spark中是否有类似的功能可以与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

据我所知JavaDStream有两个选项：

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

你试过那些吗？

Answer 2

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

将 DStream 转换为 JavaDStream

Convert DStream to JavaDStream

apache-spark

spark-streaming