SparkSQL学习- InsertIntoHiveTable类

InsertIntoHiveTable能够理解为SparkSQL物理执行计划的一个操做符,将数据价值到Hive表。它包含有ide Configuration对象 Hive表路径 HiveSessionState对象 主要逻辑在sideEffectResult方法,包括校验和设置参数,调用sc.runJob,清理临时文件,刷新Hive表元数据。具体以下code 构造FileSinkDec对象,写入文
相关文章
相关标签/搜索