我正尝试使用jupyternotebook上的以下代码将PypSparkDataframe写入配置单元表:
df.repartition("dt").write.partitionBy("dt").format("orc").saveAsTable(fraud_nr.test)
ruu nr是我试图将表写入的数据库。但我犯了个错误。
> NameError: name 'fraud_nr' is not defined
我想知道我还需要做什么才能写入这个数据库。
我正尝试使用jupyternotebook上的以下代码将PypSparkDataframe写入配置单元表:
df.repartition("dt").write.partitionBy("dt").format("orc").saveAsTable(fraud_nr.test)
ruu nr是我试图将表写入的数据库。但我犯了个错误。
> NameError: name 'fraud_nr' is not defined
我想知道我还需要做什么才能写入这个数据库。
1条答案
按热度按时间inb24sb21#
保持
db_name.table_name
用引号括起来(“”)