Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/19649#discussion_r149004933
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/ExternalCatalog.scala
---
@@ -158,7 +173,13 @@ abstract class ExternalCatalog
* @param table Name of table to alter schema for
* @param newDataSchema Updated data schema to be used for the table.
*/
- def alterTableDataSchema(db: String, table: String, newDataSchema:
StructType): Unit
+ final def alterTableDataSchema(db: String, table: String, newDataSchema:
StructType): Unit = {
+ postToAll(AlterTableSchemaPreEvent(db, table))
--- End diff --
For me I think it is not so necessary to carry the new schema, we can query
the catalog by `db` and `table` to get this newly set schema.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
