無法通過scala導入spark2.1.0中的StreamingContext

Question

我是大數據環境的新手，所以我不太瞭解，但是我已經研究並在我的pom文件中添加了依賴項，但是我無法創建spark StreamingContext。我附上相關性的圖像和下面的錯誤

• Showing error not found type StreamingContext
• List of dependency i have pasted in my pom file

任何幫助將是很大的幫助。 我正在使用spark版本2.1.0和scala版本2.11.8

Answer 1

請注意您的進口情況。

從Spark API我們可以看到：

的StreamingContext對象的絕對包路徑是

org.apache.spark.streaming.StreamingContext 

但你的圖像顯示了你有這樣的進口模式。

import org.apache.spark._ 

這就是爲什麼你的IDE無法找到的StreamingContext的參考點。

的解決方案是明確的，兩種選擇：

1. import org.apache.spark.streaming._
2. import org.apache.spark._並參考其streaming.StreamingContext程序