我想从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查询正在工作并返回数据…那么我遗漏了什么呢?
谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!