From 931de3dde9565eae0db312b4be7b8064d97668dc Mon Sep 17 00:00:00 2001 From: yanz Date: Mon, 25 Nov 2024 19:20:14 +0800 Subject: [PATCH] fix fucking format Signed-off-by: yanz --- .../connector/iceberg/CachingIcebergCatalog.java | 8 +------- 1 file changed, 1 insertion(+), 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 index 81f993dcfa840..dd5294e33a2c4 100644 --- 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 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()