2016-08-31 39 views
0

我正在选择一个整个表并将其加载到一个新的表中。它的加载是正确的,但该值附加不覆盖。 星火1.6版 下面的代码片段将Hive上下文加载到表中

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

我滴速和创建表(employee)及以上code.But执行的仍然是旧行值获取与新row.For附加例如,如果我插入四行并放下表格,再插入四行,总共添加了8行。好心帮助我,如何覆盖数据而不是追加。

问候 普拉卡什

回答

3

尝试

String query="insert overwrite table employee select * from tempregtable"; 

INSERT OVERWRITE将覆盖在表或分区的任何现有数据

INSERT INTO将附加到表或分区

参考:Hive Language Manual

相关问题