Apache Spark：无法解析构造函数 StreamingContext

Question

我一直在尝试在我的程序中建立一个 StreamingContext，但我一生都无法弄清楚发生了什么。我将 spark-streaming jar 文件添加到依赖项中并将其导入代码中，但我不禁觉得我在某处遗漏了一些小细节。我应该如何进行？

picture of code

Answer 1

您忘记在您的情况下导入 StreamingContext。

使用

import org.apache.spark.streaming.StreamingContext

没有

import org.apache.spark.streaming.StreamingContext._

它将导入内部对象而不是类。