write pyspark dataframe to hive table-name'database'is not defined error apache spark-将pysparkDataframe写入配置单元表-未定义名称'database'

qltillow  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(530)

我正尝试使用jupyternotebook上的以下代码将PypSparkDataframe写入配置单元表:

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

ruu nr是我试图将表写入的数据库。但我犯了个错误。

> NameError: name 'fraud_nr' is not defined

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

inb24sb2

inb24sb21#

保持 db_name.table_name 用引号括起来(“”)

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

相关问题