sparksql：使用registerEmptable（）将数据帧注册为表

Question

我正在使用registerTempTable()方法将dataframedf注册为一个名为dataset的表。在

然后，我运行SQLContext方法tableNames以返回表列表。在

from pyspark.sql import SQLContext
import findspark
findspark.init()
import pyspark
sc = pyspark.SparkContext()
sqlCtx = SQLContext(sc)
df = sqlCtx.read.json("dataset.json")
df.registerTempTable('dataset')
tables = sqlCtx.tableNames()
print(tables)

我有个错误：

AttributeError: 'DataFrame' object has no attribute 'registerTempTable'

你能帮我解决这个问题吗。谢谢您。在

Answer 1

此函数自2.0.0registerTempTable(tableName:String)起已被弃用。在

您应该改用createOrReplaceTempView()。在

Note:: Deprecated in 2.0, use createOrReplaceTempView instead

检查火花documentation。在