Я пытался установить StreamingContext в моей программе, но я не могу понять, что происходит. Я добавил файл jar для потокового воспроизведения в зависимости и импортировал его в код, но я не могу избавиться от ощущения, что упускаю какую-то маленькую деталь. Как мне поступить?
изображение кода
Вы забыли импортировать StreamingContext в вашем случае.
Использование
import org.apache.spark.streaming.StreamingContext
Не
import org.apache.spark.streaming.StreamingContext._
Импортирует внутренние объекты, а не класс.