Skip to content

Commit bf42988

Browse files
committed
Refactor EntityCache to an interface
1 parent 250bdec commit bf42988

File tree

11 files changed

+541
-445
lines changed

11 files changed

+541
-445
lines changed

polaris-core/src/main/java/org/apache/polaris/core/persistence/LocalPolarisMetaStoreManagerFactory.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import org.apache.polaris.core.entity.PolarisEntityType;
3535
import org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet;
3636
import org.apache.polaris.core.persistence.cache.EntityCache;
37+
import org.apache.polaris.core.persistence.cache.InMemoryEntityCache;
3738
import org.apache.polaris.core.persistence.dao.entity.BaseResult;
3839
import org.apache.polaris.core.persistence.dao.entity.EntityResult;
3940
import org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult;
@@ -190,7 +191,8 @@ public synchronized StorageCredentialCache getOrCreateStorageCredentialCache(
190191
public synchronized EntityCache getOrCreateEntityCache(RealmContext realmContext) {
191192
if (!entityCacheMap.containsKey(realmContext.getRealmIdentifier())) {
192193
PolarisMetaStoreManager metaStoreManager = getOrCreateMetaStoreManager(realmContext);
193-
entityCacheMap.put(realmContext.getRealmIdentifier(), new EntityCache(metaStoreManager));
194+
entityCacheMap.put(
195+
realmContext.getRealmIdentifier(), new InMemoryEntityCache(metaStoreManager));
194196
}
195197

196198
return entityCacheMap.get(realmContext.getRealmIdentifier());

0 commit comments

Comments
 (0)