2017-01-13 46 views
1

我學習的Spark現在當我試圖加載JSON文件,如下所示:如何修復這個錯誤:「SQLContext對象沒有沒有屬性‘jsonFile’

people=sqlContext.jsonFile("C:\wdchentxt\CustomerData.json") 

我得到了以下錯誤:

AttributeError: 'SQLContext' object has no attribute 'jsonFile' 

我在Windows上運行此7 PC,與火花2.1.0彬hadoop2.7和Python 2.7.13(2016年12月17日)。

感謝您的任何建議你可能有。

+0

我在macOS上有Spark 2.0.0。但是,你可以檢查'sqlContext.read.json()'是否適合你?對我來說,如果我想自定義配置我的spark,我也可以'sc = SparkContext(conf = conf)'然後'sqlContext = SQLContext(sc)' – titipata

+3

'.jsonFile'已被棄用;你應該使用'.read.json()'來代替。 –

+0

謝謝大家的快速幫助。當我用「read.json」替換「.jsonFile」時它就起作用了。這是一個簡單的修復。 – user281707

回答

1

你可能忘記了導入implicits。這就是我的解決方案在Scala中的樣子:

def loadJson(filename: String, sqlContext: SqlContext): Dataset[Row] = { 
    import sqlContext._ 
    import sqlContext.implicits._ 
    val df = sqlContext.read.json(filename) 
    df 
} 
相關問題