fix fucking format

Signed-off-by: yanz <[email protected]>
StarRocks · Nov 25, 2024 · 931de3d · 931de3d
1 parent 09eb386
commit 931de3d
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/CachingIcebergCatalog.java b/fe/fe-core/src/main/java/com/starrocks/connector/iceberg/CachingIcebergCatalog.java
@@ -88,13 +88,7 @@ public CachingIcebergCatalog(String catalogName, IcebergCatalog delegate, Iceber
                 enableCache ? DEFAULT_CACHE_NUM : NEVER_CACHE).build();
         this.partitionCache = newCacheBuilder(icebergProperties.getIcebergMetaCacheTtlSec(),
                 enableCache ? DEFAULT_CACHE_NUM : NEVER_CACHE).build(
-            new CacheLoader<>() {
-                @Override
-                public Map<String, Partition> load(IcebergTableName key) throws Exception {
-                    // use default executor service.
-                    return delegate.getPartitions(key.dbName, key.tableName, key.snapshotId, null);
-                }
-            });
+                CacheLoader.from(key -> delegate.getPartitions(key.dbName, key.tableName, key.snapshotId, null)));
         this.dataFileCache = enableCache ?
                 newCacheBuilder(
                         icebergProperties.getIcebergMetaCacheTtlSec(), icebergProperties.getIcebergManifestCacheMaxNum()).build()