通过 SQL ALTER TABLE 命令将列添加到 Spark Table

Question

我可以使用 ALTER TABLE 命令向现有 spark table 添加新列吗？

var query = "ALTER TABLE " + "global_temp." + tableName(0) + " ADD COLUMN " + newColumnName + " " + newColumnDatatype
var drt = spark.sql(query)

以上代码引发了以下错误。

 no viable alternative at input 'ALTER TABLE global_temp.people_ty ADD COLUMN' new_age integer

编辑

正确的语法如下

ALTER TABLE tablename ADD COLUMNS (newColumn newDataType)

但是，它也会抛出以下错误。

ALTER ADD COLUMNS does not support views.
You must drop and re-create the views for adding the new columns. Views: `global_temp`.`people_ty`

Answer 1

在 Spark SQL 中，Soumyadip Ghosh 在评论中提到了语法

ALTER TABLE table_identifier ADD COLUMNS ( col_spec [ , ... ] )

适合我。

Adding a Column to Spark Table via SQL ALTER TABLE command