看起来 hivereplace columns
不适用于 spark 2.2.1 和 2.3.1
alterSchemaSql : alter table myschema.mytable replace columns (a int,b int,d int)
Exception in thread "main" org.apache.spark.sql.catalyst.parser.ParseException:
Operation not allowed: alter table replace columns(line 2, pos 6)
看起来它已在ADD COLUMNS
2.2 版本以后修复。它也适用于我,但replace columns
仍然失败。
不允许的操作:alter table add columns(line 1, pos 0)
以下文档说应该支持它。不知道为什么它对我来说失败了。 https://spark.apache.org/docs/2.2.0/sql-programming-guide.html#supported-hive-features