2016-08-31 40 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

相關問題