delta格式更新查询

5tmbdcev  于 2021-05-17  发布在  Spark
关注(0)|答案(0)|浏览(317)

我试图在sparksql中对delta表执行一个简单的更新查询

update fact
set
fact.Invoice_Status=inv.Invoice_Status
,fact.Error_Reason=inv.Error_Reason
,fact.End_Date=current_date()
from fact_invoice fact inner join (select * from Invoice) inv on (fact.Data_Source= inv.Data_Source 
and fact.Legal_entity=inv.Legal_entity
and fact.Invoice_ID=inv.Invoice_ID and fact.Invoice_Number=inv.Invoice_Number)

但是它抛出了一个错误,作为来自'expecting{,';'}的不匹配输入'这个精确的查询在rdbms sql中工作得非常好,如果我遗漏了什么,请帮助我。
谢谢

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题