(paimon) branch master updated: [hotfix] Make refreshPartitions in CachingCatalog public

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new da23f55a1 [hotfix] Make refreshPartitions in CachingCatalog public
da23f55a1 is described below

commit da23f55a150718ed5a7fedc87ee4040b45a62f7e
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Tue Nov 5 16:45:15 2024 +0800

    [hotfix] Make refreshPartitions in CachingCatalog public
---
 .../java/org/apache/paimon/catalog/CachingCatalog.java  | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java 
b/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java
index 03edbaab7..1a6b23078 100644
--- a/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java
+++ b/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java
@@ -266,13 +266,6 @@ public class CachingCatalog extends DelegateCatalog {
         return result;
     }
 
-    public void refreshPartitions(Identifier identifier) throws 
TableNotExistException {
-        if (partitionCache != null) {
-            List<PartitionEntry> result = wrapped.listPartitions(identifier);
-            partitionCache.put(identifier, result);
-        }
-    }
-
     @Override
     public void dropPartition(Identifier identifier, Map<String, String> 
partitions)
             throws TableNotExistException, PartitionNotExistException {
@@ -314,4 +307,14 @@ public class CachingCatalog extends DelegateCatalog {
         }
         return tables;
     }
+
+    // ================================== refresh 
================================================
+    // following caches will affect the latency of table, so refresh method is 
provided for engine
+
+    public void refreshPartitions(Identifier identifier) throws 
TableNotExistException {
+        if (partitionCache != null) {
+            List<PartitionEntry> result = wrapped.listPartitions(identifier);
+            partitionCache.put(identifier, result);
+        }
+    }
 }