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 index 42762f745dae..5f24d5cf8535 100644 --- 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 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 index 39f72ef5a717..3e4781086495 100644 --- 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; }