我正在选择整个表并将其加载到新表中。该表已正确加载,但值正在追加而不是覆盖。下面的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行。请帮助我,如何覆盖数据而不是追加。
向普拉卡什问好
1条答案
按热度按时间cnwbcb6i1#
尝试