hortonworks hive warehouse connector到v.1.0.0似乎不支持模式更新。我试着用
hive
.createTable(tableName)
.ifNotExists()
.column(name, type)
.create()
如果表存在,但具有不同的模式,并且什么也没有发生。然后我尝试用不同的模式编写Dataframe。
dataFrame
.write
.format("com.hortonworks.spark.sql.hive.llap.HiveWarehouseConnector")
.save()
什么也没发生。我希望analysisexception应该像spark那样抛出。
1条答案
按热度按时间0sgqnhkj1#
我发现要创建一个hwc表,需要生成一个查询。。。
仅当表不存在且方案不比较时才执行。然后请求插入数据。。。
根据文件。。。
load命令不执行针对模式的数据验证。
因此,如果方案改变,hwc就可以将这个Dataframe记录在hive存储器中,在hive存储器中,具有不同方案的旧表可以毫无例外地保存数据。