我怎麼能轉換pyspark.sql.dataframe.DataFrame回SQL表中databricks筆記本

我通過執行以下行創建pyspark.sql.dataframe.DataFrame類型的數據幀： dataframe = sqlContext.sql("select * from my_data_table")我怎麼能轉換pyspark.sql.dataframe.DataFrame回SQL表中databricks筆記本

我如何轉換這回sparksql表，我可以運行SQL查詢？

2016-08-19 Semihcan

您可以使用createReplaceTempView創建表格。在你的情況下，它會像：

dataframe.createOrReplaceTempView("mytable")

這之後您可以使用SQL 查詢您mytable。

如果你的火花版本是1.6.2≤你可以使用registerTempTable

2016-08-19 23:21:54

當我運行'dataframe.createOrReplaceTempView（「MYTABLE」）' 我得到以下錯誤：「數據幀」對象有沒有屬性' createOrReplaceTempView' – Semihcan

你使用的是什麼版本的Apache spark？ –

我正在使用1.5.2 – Semihcan

回答