add catalog meta cache

apache · Jan 10, 2025 · d7b9582 · d7b9582
1 parent fc1d05a
commit d7b9582
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 8 deletions.
diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/AmoroManagementConf.java b/amoro-ams/src/main/java/org/apache/amoro/server/AmoroManagementConf.java
@@ -51,8 +51,8 @@ public class AmoroManagementConf {
           .defaultValue("admin")
           .withDescription("The administrator password");
 
-  public static final ConfigOption<Duration> CACHE_CATALOG_META_DURATION =
-      ConfigOptions.key("cache.catalog-meta.duration")
+  public static final ConfigOption<Duration> CATALOG_META_CACHE_EXPIRATION_INTERVAL =
+      ConfigOptions.key("catalog-meta-cache.expiration-interval")
           .durationType()
           .defaultValue(Duration.ofSeconds(60))
           .withDescription("TTL for catalog metadata.");

diff --git a/amoro-ams/src/main/java/org/apache/amoro/server/catalog/DefaultCatalogManager.java b/amoro-ams/src/main/java/org/apache/amoro/server/catalog/DefaultCatalogManager.java
@@ -52,7 +52,8 @@ public class DefaultCatalogManager extends PersistentBase implements CatalogMana
 
   public DefaultCatalogManager(Configurations serverConfiguration) {
     this.serverConfiguration = serverConfiguration;
-    Duration cacheTtl = serverConfiguration.get(AmoroManagementConf.CACHE_CATALOG_META_DURATION);
+    Duration cacheTtl =
+        serverConfiguration.get(AmoroManagementConf.CATALOG_META_CACHE_EXPIRATION_INTERVAL);
     metaCache =
         CacheBuilder.newBuilder()
             .maximumSize(100)
@@ -80,8 +81,7 @@ public DefaultCatalogManager(Configurations serverConfiguration) {
 
   @Override
   public List<CatalogMeta> listCatalogMetas() {
-    return getAs(CatalogMetaMapper.class, CatalogMetaMapper::getCatalogs)
-        .stream()
+    return getAs(CatalogMetaMapper.class, CatalogMetaMapper::getCatalogs).stream()
         .peek(c -> metaCache.put(c.getCatalogName(), Optional.of(c)))
         .collect(Collectors.toList());
   }

diff --git a/dist/src/main/amoro-bin/conf/config.yaml b/dist/src/main/amoro-bin/conf/config.yaml
@@ -91,9 +91,8 @@ ams:
   table-manifest-io:
     thread-count: 20
 
-  cache:
-    catalog-meta:
-      duration: 60s
+  catalog-meta-cache:
+    expiration-interval: 60s
 
   database:
     type: derby