我遵循了此處的解決方案,但是,我仍然收到“無法決議符號 SQLContext”錯誤。“.implicits._”也無法決議。原因是什么?
我使用的 Spark/Scala 版本:
- 斯卡拉 2.12.13
- Spark 3.0.1(沒有捆綁的 Hadoop)
這是我的相關代碼部分:
import org.apache.log4j.LogManager
import org.apache.spark.{SparkConf, SparkContext}
object Count {
def main(args: Array[String]) {
...
...
val sc = new SparkContext(conf)
val sqlContext = new SQLContext(sc)
import sqlContext.implicits._
}}
uj5u.com熱心網友回復:
您根本沒有匯入SQLContext:
import org.apache.spark.sql.SQLContext
不過,您可能一開始就不應該再使用SQLContext了:
從 Spark 2.0 開始,它被 SparkSession 取代。但是,我們將類保留在這里是為了向后兼容。
https://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/SQLContext.html
在如何從現有 SparkContext 中創建 SparkSession 中查看如何使用SparkSessionfrom ,然后。SparkContextimport sparkSession.implicits._
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/436849.html
