Spark落地到hive表中的兩種方式及其區別


方式一:

SavaAsTable

用法:

df.write.mode(SaveMode.Overwrite).insertInto(table)

方式二:

InsertInto

用法:

df.write.mode(SaveMode.Overwrite).saveAsTable(table)

兩種方式主要區別:

SaveAsTable方式,當hive中已經存在目標表,無論SaveMode是append還是overwrite,不需要schema一樣,只要列名存在就行,會根據列名進行匹配覆蓋數據

InsertInto方式,當hive中存在目標表時,無論SaveMode是append還是overwrite,需要當前DF的schema與目標表的schema必須一致


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM