我刚刚开始使用 Hive。我正在 Databricks 社区工作。我用 python 编写,但想用 SQL 编写一些东西,但有一个我无法理解的错误。我看不出我的代码有什么问题。请帮助我。
spark.sql("create table happiness_perm as select * from happiness_tmp");
%sql
select Country, count(*) from happiness_perm group by Country
我尝试使用我的数据框架 df_happiness 而不是 happy_perm,但我仍然收到这个:
SQL语句错误:AnalyseException:找不到表或视图:happiness_perm;第 1 行 pos 30; '聚合['国家/地区],['国家/地区,未解决的别名(计数(1),无)] +- 'UnresolvedRelation [happiness_perm], [], false
我非常感谢您的帮助!
试试这个:
df = spark.sql("select * from happiness_tmp")
df.createOrReplaceTempView("happiness_perm")
首先将数据放入数据帧中,然后将数据帧的内容写入目录中的表中。
然后就可以查询该表了。