Создание объекта Spark JavaDStream из объекта потока Java 8 - PullRequest
0 голосов
/ 18 октября 2018

Как видно из заголовка, есть ли способ создать объект 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.

...