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

zqry0prt 于 2021-06-28 发布在 Hive

关注(0)|答案(1)|浏览(481)

我正在选择整个表并将其加载到新表中。该表已正确加载，但值正在追加而不是覆盖。下面的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行。请帮助我，如何覆盖数据而不是追加。
向普拉卡什问好

Hive apache-spark hiveql hadoop2

来源：https://stackoverflow.com/questions/39241301/hive-context-to-load-into-a-table

1条答案

按热度按时间

cnwbcb6i1#

尝试

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

赞(0）回复(0）举报 2021-06-28

我来回答

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

1条答案

相关问题

热门标签

最新问答