python - 如何将 pyspark.sql.dataframe.DataFrame 转换回 databricks 笔记本中的 sql 表

Question

pyspark.sql.dataframe.DataFrame我通过执行以下行 创建了一个类型的数据框：dataframe = sqlContext.sql("select * from my_data_table")

如何将其转换回可以运行 sql 查询的 sparksql 表？

Answer 1

您可以使用createReplaceTempView创建表。在你的情况下，它会像：

dataframe.createOrReplaceTempView("mytable")

在此之后，您可以查询您mytable使用的SQL。

如果您的火花版本≤1.6.2，您可以使用registerTempTable