[SC-86844] Refactor alterDeltaTableCommands

Refactor schemaEqual method in alterDeltaTableCommands. GitOrigin-RevId: de64cae3c1a032c54bf2624e7aaf1897bdb12d09
varuy322 · Oct 28, 2021 · c1fce21 · c1fce21
1 parent 1732170
commit c1fce21
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/sql/delta/commands/alterDeltaTableCommands.scala b/core/src/main/scala/org/apache/spark/sql/delta/commands/alterDeltaTableCommands.scala
@@ -506,8 +506,11 @@ case class AlterTableSetLocationDeltaCommand(
 
   private def schemasEqual(
       oldMetadata: actions.Metadata, newMetadata: actions.Metadata): Boolean = {
-    oldMetadata.schema == newMetadata.schema &&
-      oldMetadata.partitionSchema == newMetadata.partitionSchema
+    import DeltaColumnMapping._
+    dropColumnMappingMetadata(oldMetadata.schema) ==
+      dropColumnMappingMetadata(newMetadata.schema) &&
+      dropColumnMappingMetadata(oldMetadata.partitionSchema) ==
+        dropColumnMappingMetadata(newMetadata.partitionSchema)
   }
 
   // TODO: remove when the new Spark version is releases that has the withNewChildInternal method