python - 如何解决此错误:“SQLContext对象没有属性'jsonFile'

我正在学习Spark。当我尝试加载json文件时，如下所示：

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

我收到以下错误：

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

我在带有spark-2.1.0-bin-hadoop2.7和Python 2.7.13的Windows 7 PC上运行此程序（2016年12月17日）。

感谢您提出的任何建议。

最佳答案

您可能忘记了导入隐式。这是我的解决方案在Scala中的样子：

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

关于python - 如何解决此错误:“SQLContext对象没有属性'jsonFile'，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/41641749/