createDataFrame在Spark 2.0.0中不起作用



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

属性

错误:"函数"对象没有属性"创建数据帧">

spark = SparkSession.builder.master("local").appName("Search").config(conf=SparkConf()).getOrCreate
d = [{'name': 'Alice', 'age': 1}]
spark.createDataFrame(d).collect()

有人可以解释我需要做什么来修复此错误吗?我已经搜索了官方文档,没有找到有关此特定错误的任何内容。谢谢。

getOrCreateSparkSession.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错误非常常见。

最新更新