将sql查询结果写入databricks中的temp视图

kzmpq1sx  于 2021-07-12  发布在  Spark
关注(0)|答案(0)|浏览(235)

我想从sql查询的结果中创建一个临时视图—这听起来像是一个基本的操作,但我就是无法使它工作,也不明白哪里出了问题。
这是我的sql查询-工作正常并返回col1。

%sql
SELECT
  Col1
  FROM
  Table1
    WHERE EXISTS (
      select * 
        from TempView1)

我想把结果写在另一个我可以查询的表中。因此,我这样做:

df = spark.sql("""
SELECT
  Col1
  FROM
  Table1
    WHERE EXISTS (
      select * 
        from TempView1)""")

好 啊

df

out[28]:Dataframe[col1:bigint]

df.createOrReplaceTempView("df_tmp_view")

好 啊

%sql
select * from df_tmp_view

sql语句错误:analysisexception:找不到表或视图:df\u tmp\u view;第1行位置14;'项目[*]+-'未解决关系[df\u tmp\u view],[],false

display(affected_customers_tmp_view)

名称错误:未定义名称“df\u tmp\u view”
我做错什么了?我不理解这个错误,说这个名字没有定义,虽然我只定义了上面的一个命令。而且sql查询正在工作并返回数据…那么我遗漏了什么呢?
谢谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题