将 Pyspark 数据框写入 Hive 表 - 未定义名称“数据库”错误

Question

我正在尝试使用 Jupyternotebook 上的以下代码将 pyspark 数据帧写入配置单元表：

df.repartition("dt").write.partitionBy("dt").format("orc").saveAsTable(fraud_nr.test)

fraud_nr 是我试图将表写入的数据库。但是我得到了这个错误。

> NameError: name 'fraud_nr' is not defined

我想知道我还需要做什么才能写入这个数据库。

Answer 1

将 db_name.table_name 括在 quotes(")

中

df.repartition("dt").write.partitionBy("dt").format("orc").saveAsTable("fraud_nr.test")