createDataFrame 在 Spark 2.0.0 中不起作用

Question

我正在尝试完成新 Spark 2.0 文档中的一些示例。我在 Jupyter Notebooks 和命令行中工作。我可以毫无问题地创建SparkSession。但是，当我尝试创建 dataframe 时，出现以下错误：

AttributeError: 'function' 对象没有属性 'createDataFrame'

spark = SparkSession.builder.master("local").appName("Search").config(conf=SparkConf()).getOrCreate

d = [{'name': 'Alice', 'age': 1}]
spark.createDataFrame(d).collect()

有人可以解释我需要做什么来解决这个错误吗？我已经搜索了官方文档，没有发现任何关于这个特定错误的信息。谢谢。

Answer 1

getOrCreate 是SparkSession.Builder 上的一个方法。您需要通过在后面添加括号来调用它：

spark = SparkSession.builder.master("local").appName("Search").config(conf=SparkConf()).getOrCreate()

查看更多信息：https://spark.apache.org/docs/2.0.1/api/java/org/apache/spark/sql/SparkSession.html

一般来说，'function' object has no attribute 错误在您不小心引用一个函数而不是调用它时非常常见。