我通过执行以下行创建了 pyspark.sql.dataframe.DataFrame 类型的数据框:
dataframe = sqlContext.sql("select * from my_data_table")
如何将其转换回可以运行 sql 查询的 sparksql 表？
最佳答案
您可以使用 createReplaceTempView 创建表格.在你的情况下它会是这样的:
dataframe.createOrReplaceTempView("mytable")
在此之后，您可以使用 SQL 查询您的 mytable。
如果你的 spark 版本是 ≤ 1.6.2 你可以使用 registerTempTable
关于python - 如何将 pyspark.sql.dataframe.DataFrame 转换回 databricks notebook 中的 sql 表，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39048777/