Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19649#discussion_r148783615
--- 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 --
shall we carry the new schema?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
