createDataFrame无法在Spark 2.0.0中工作

Question

我正在尝试通过新的Spark 2.0文档中的一些示例。我在Jupyter笔记本和命令行工作。我可以创建一个SparkSession没有问题。然而，当我尝试创建一个dataframe我得到的错误：

AttributeError: 'function' object has no attribute '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错误是很常见的，当你不小心引用的函数，而不是调用它。