Move updateColumnComment next to updateTableComment

trinodb · Mar 4, 2022 · c55bc4f · c55bc4f
1 parent 902f4b2
commit c55bc4f
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/TrinoHiveCatalog.java
@@ -375,6 +375,15 @@ public void updateTableComment(ConnectorSession session, SchemaTableName schemaT
         }
     }
 
+    @Override
+    public void updateColumnComment(ConnectorSession session, SchemaTableName schemaTableName, ColumnIdentity columnIdentity, Optional<String> comment)
+    {
+        metastore.commentColumn(schemaTableName.getSchemaName(), schemaTableName.getTableName(), columnIdentity.getName(), comment);
+
+        Table icebergTable = loadTable(session, schemaTableName);
+        icebergTable.updateSchema().updateColumnDoc(columnIdentity.getName(), comment.orElse(null)).commit();
+    }
+
     @Override
     public String defaultTableLocation(ConnectorSession session, SchemaTableName schemaTableName)
     {
@@ -723,15 +732,6 @@ private List<String> listNamespaces(ConnectorSession session, Optional<String> n
         return listNamespaces(session);
     }
 
-    @Override
-    public void updateColumnComment(ConnectorSession session, SchemaTableName schemaTableName, ColumnIdentity columnIdentity, Optional<String> comment)
-    {
-        metastore.commentColumn(schemaTableName.getSchemaName(), schemaTableName.getTableName(), columnIdentity.getName(), comment);
-
-        Table icebergTable = loadTable(session, schemaTableName);
-        icebergTable.updateSchema().updateColumnDoc(columnIdentity.getName(), comment.orElse(null)).commit();
-    }
-
     private static class MaterializedViewMayBeBeingRemovedException
             extends RuntimeException
     {