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錯誤是很常見的，當你不小心引用的函數，而不是調用它。