SparkSQL學習- InsertIntoHiveTable類

InsertIntoHiveTable能夠理解爲SparkSQL物理執行計劃的一個操做符,將數據價值到Hive表。它包含有ide Configuration對象 Hive表路徑 HiveSessionState對象 主要邏輯在sideEffectResult方法,包括校驗和設置參數,調用sc.runJob,清理臨時文件,刷新Hive表元數據。具體以下code 構造FileSinkDec對象,寫入文
相關文章
相關標籤/搜索