Как видно из заголовка, есть ли способ создать объект Spark org.apache.spark.streaming.api.java.JavaDStream
из объекта java.util.Stream
?По сути, я искал метод, который бы делал что-то вроде этого
public <T> org.apache.spark.streaming.api.java.JavaDStream<T> fromJavaStream(java.util.Stream<T> javaStream);
Я просмотрел доступную здесь документацию, но не смог найти никаких вспомогательных методов, которые могли бы помочь мне в этом.Я видел, что вы можете создать объект DStream из сокета или файла, используя объект JavaStreamingContext.