如何将pyspark.sql.dataframe.dataframe转换回databricks noteb中的sql表

Question

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

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

Answer 1

可以使用createReplaceTempView创建表。在你的情况下，可能是：

dataframe.createOrReplaceTempView("mytable")

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

如果您的a spark版本小于等于1.6.2，则可以使用registerTempTable