无法通过 scala 导入 spark2.1.0 中的 StreamingContext

Question

我是大数据环境的新手，所以我不太了解，但是我在POM文件中研究并增加了依赖性，但是我无法创建SPARK StreamingContext。我正在附上依赖性图像和下面的错误

• 显示未找到错误的错误类型streamcontext
• 依赖性列表我粘贴了我的pom文件

任何帮助都会有很大的帮助。我正在使用spark版本2.1.0和scala版本2.11.8

Answer 1

请更加谨慎。

从Spark API中我们可以看到：

streamcontext对象的绝对软件包路径是

org.apache.spark.streaming.StreamingContext

，但是您的图像显示您具有此导入模式。

import org.apache.spark._

这是您的IDE找不到streamingContext引用的重点。

解决方案很清楚，有两个选择：

1. import org.apache.spark.streaming._
2. import org.apache.spark._并参考 streaming.streamingcontext in Program