Sparksql中插入數據時,若是記.錄不存在則insert,若是存在則update

最近在寫項目的時候,碰到了須要經過Sparksql對數據庫數據根據主鍵進行存在即覆蓋,不存在則追加的操做,記得在之前的使用2.1.0版本的spark的時候,我是使用了replace into完成了這種操做,但如今公司項目是2.3.1版本,replace into不被支持了,很鬱悶,在網上找了不少相關操做的博客,都沒有我想要的結果,最後乾脆用代碼解決問題! 先上代碼:web Dataset<Row>
相關文章
相關標籤/搜索