fix

apache · Jul 29, 2024 · bc7f6b1 · bc7f6b1
1 parent 254c881
commit bc7f6b1
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 4 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/DelegateCatalog.java
@@ -37,6 +37,10 @@ public DelegateCatalog(Catalog wrapped) {
         this.wrapped = wrapped;
     }
 
+    public Catalog wrapped() {
+        return wrapped;
+    }
+
     @Override
     public boolean caseSensitive() {
         return wrapped.caseSensitive();
@@ -136,6 +140,21 @@ public void dropPartition(Identifier identifier, Map<String, String> partitions)
         wrapped.dropPartition(identifier, partitions);
     }
 
+    @Override
+    public void repairCatalog() {
+        wrapped.repairCatalog();
+    }
+
+    @Override
+    public void repairDatabase(String databaseName) {
+        wrapped.repairDatabase(databaseName);
+    }
+
+    @Override
+    public void repairTable(Identifier identifier) throws TableNotExistException {
+        wrapped.repairTable(identifier);
+    }
+
     @Override
     public void close() throws Exception {
         wrapped.close();

diff --git a/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java b/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedCatalog.java
@@ -49,10 +49,6 @@ public PrivilegedCatalog(Catalog wrapped, PrivilegeManager privilegeManager) {
         this.privilegeManager = privilegeManager;
     }
 
-    public Catalog wrapped() {
-        return wrapped;
-    }
-
     public PrivilegeManager privilegeManager() {
         return privilegeManager;
     }