要加载到表中的配置单元上下文

zqry0prt  于 2021-06-28  发布在  Hive
关注(0)|答案(1)|浏览(368)

我正在选择整个表并将其加载到新表中。该表已正确加载,但值正在追加而不是覆盖。下面的spark版本1.6是代码片段

DataFrame df = hiveContext.createDataFrame(JavaRDD<Row>, StructType);
df.registerTempTable("tempregtable"); 
String query="insert into employee select * from tempregtable";
hiveContext.sql(query);

我正在删除并创建表(employee)并执行上面的代码。但是旧的行值仍然会附加新行。例如,如果我插入四行并删除表,然后再次插入四行,总共添加了8行。请帮助我,如何覆盖数据而不是追加。
向普拉卡什问好

cnwbcb6i

cnwbcb6i1#

尝试

String query="insert overwrite table employee select * from tempregtable";
``` `INSERT OVERWRITE` 将覆盖表或分区中的任何现有数据 `INSERT INTO` 将附加到表或分区
参考:配置单元语言手册

相关问题