Package org.apache.polaris.persistence.relational.jdbc

Class JdbcMetaStoreManagerFactory

java.lang.Object
org.apache.polaris.persistence.relational.jdbc.JdbcMetaStoreManagerFactory
All Implemented Interfaces:
org.apache.polaris.core.persistence.MetaStoreManagerFactory
@ApplicationScoped @Identifier("relational-jdbc") public class JdbcMetaStoreManagerFactory extends Object implements org.apache.polaris.core.persistence.MetaStoreManagerFactory
JDBC-based implementation of MetaStoreManagerFactory that creates and manages PolarisMetaStoreManager instances backed by a relational SQL metastore.

This factory is responsible for: - Bootstrapping realms - Managing per-realm persistence sessions - Caching schema versions and bootstrap state - Providing entity caches for runtime operations

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    JdbcMetaStoreManagerFactory()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Map<String,org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult>
    bootstrapRealms(Iterable<String> realms, org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet)
     
    Map<String,org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult>
    bootstrapRealms(org.apache.polaris.core.persistence.bootstrap.BootstrapOptions bootstrapOptions)
     
    protected org.apache.polaris.core.persistence.PolarisMetaStoreManager
    createNewMetaStoreManager()
     
    org.apache.polaris.core.persistence.cache.EntityCache
    getOrCreateEntityCache(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfig realmConfig)
     
    org.apache.polaris.core.persistence.PolarisMetaStoreManager
    getOrCreateMetaStoreManager(org.apache.polaris.core.context.RealmContext realmContext)
     
    org.apache.polaris.core.persistence.BasePersistence
    getOrCreateSession(org.apache.polaris.core.context.RealmContext realmContext)
     
    Map<String,org.apache.polaris.core.persistence.dao.entity.BaseResult>
    purgeRealms(Iterable<String> realms)
     
    protected org.apache.polaris.core.persistence.PrincipalSecretsGenerator
    secretsGenerator(String realmId, @Nullable org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • JdbcMetaStoreManagerFactory

      protected JdbcMetaStoreManagerFactory()

  • Method Details

    • secretsGenerator

      protected org.apache.polaris.core.persistence.PrincipalSecretsGenerator secretsGenerator(String realmId, @Nullable org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet)

    • createNewMetaStoreManager

      protected org.apache.polaris.core.persistence.PolarisMetaStoreManager createNewMetaStoreManager()

    • bootstrapRealms

      public Map<String,org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult> bootstrapRealms(Iterable<String> realms, org.apache.polaris.core.persistence.bootstrap.RootCredentialsSet rootCredentialsSet)
      Specified by:
      bootstrapRealms in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory

    • bootstrapRealms

      public Map<String,org.apache.polaris.core.persistence.dao.entity.PrincipalSecretsResult> bootstrapRealms(org.apache.polaris.core.persistence.bootstrap.BootstrapOptions bootstrapOptions)
      Specified by:
      bootstrapRealms in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory

    • purgeRealms

      public Map<String,org.apache.polaris.core.persistence.dao.entity.BaseResult> purgeRealms(Iterable<String> realms)
      Specified by:
      purgeRealms in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory

    • getOrCreateMetaStoreManager

      public org.apache.polaris.core.persistence.PolarisMetaStoreManager getOrCreateMetaStoreManager(org.apache.polaris.core.context.RealmContext realmContext)
      Specified by:
      getOrCreateMetaStoreManager in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory

    • getOrCreateSession

      public org.apache.polaris.core.persistence.BasePersistence getOrCreateSession(org.apache.polaris.core.context.RealmContext realmContext)
      Specified by:
      getOrCreateSession in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory

    • getOrCreateEntityCache

      public org.apache.polaris.core.persistence.cache.EntityCache getOrCreateEntityCache(org.apache.polaris.core.context.RealmContext realmContext, org.apache.polaris.core.config.RealmConfig realmConfig)
      Specified by:
      getOrCreateEntityCache in interface org.apache.polaris.core.persistence.MetaStoreManagerFactory