Package org.apache.polaris.service.catalog.generic

Class GenericTableCatalogHandler

java.lang.Object

org.apache.polaris.service.catalog.common.CatalogHandler

org.apache.polaris.service.catalog.generic.GenericTableCatalogHandler

public class GenericTableCatalogHandler
extends CatalogHandler

Field Summary

Fields inherited from class org.apache.polaris.service.catalog.common.CatalogHandler

authorizer, callContext, catalogName, credentialManager, diagnostics, externalCatalogFactories, polarisPrincipal, realmConfig, resolutionManifest, resolutionManifestFactory

Constructor Summary

Constructors

Constructor

Description

GenericTableCatalogHandler(org.apache.polaris.core.PolarisDiagnostics diagnostics, org.apache.polaris.core.context.CallContext callContext, org.apache.polaris.core.persistence.resolver.ResolutionManifestFactory resolutionManifestFactory, org.apache.polaris.core.persistence.PolarisMetaStoreManager metaStoreManager, org.apache.polaris.core.auth.PolarisPrincipal principal, String catalogName, org.apache.polaris.core.auth.PolarisAuthorizer authorizer, org.apache.polaris.core.credentials.PolarisCredentialManager polarisCredentialManager, jakarta.enterprise.inject.Instance<org.apache.polaris.core.catalog.ExternalCatalogFactory> externalCatalogFactories)

Method Summary

Modifier and Type	Method	Description
org.apache.polaris.service.types.LoadGenericTableResponse	createGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier, String format, String baseLocation, String doc, Map<String,String> properties)
boolean	dropGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier)
protected void	initializeCatalog()	Initialize the catalog once authorized.
org.apache.polaris.service.types.ListGenericTablesResponse	listGenericTables(org.apache.iceberg.catalog.Namespace parent)
org.apache.polaris.service.types.LoadGenericTableResponse	loadGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier)

Methods inherited from class org.apache.polaris.service.catalog.common.CatalogHandler

authorizeBasicNamespaceOperationOrThrow, authorizeBasicNamespaceOperationOrThrow, authorizeBasicTableLikeOperationOrThrow, authorizeBasicTableLikeOperationsOrThrow, authorizeCollectionOfTableLikeOperationOrThrow, authorizeCreateNamespaceUnderNamespaceOperationOrThrow, authorizeCreateTableLikeUnderNamespaceOperationOrThrow, authorizeRenameTableLikeOperationOrThrow, ensureResolutionManifestForTable, getPolarisCredentialManager, newResolutionManifest, throwNotFoundExceptionForTableLikeEntity

Methods inherited from class java.lang.Object

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

Constructor Details

GenericTableCatalogHandler

public GenericTableCatalogHandler(org.apache.polaris.core.PolarisDiagnostics diagnostics,
 org.apache.polaris.core.context.CallContext callContext,
 org.apache.polaris.core.persistence.resolver.ResolutionManifestFactory resolutionManifestFactory,
 org.apache.polaris.core.persistence.PolarisMetaStoreManager metaStoreManager,
 org.apache.polaris.core.auth.PolarisPrincipal principal,
 String catalogName,
 org.apache.polaris.core.auth.PolarisAuthorizer authorizer,
 org.apache.polaris.core.credentials.PolarisCredentialManager polarisCredentialManager,
 jakarta.enterprise.inject.Instance<org.apache.polaris.core.catalog.ExternalCatalogFactory> externalCatalogFactories)

Method Details

initializeCatalog

protected void initializeCatalog()

Description copied from class: CatalogHandler

Initialize the catalog once authorized. Called after all `authorize...` methods.

Specified by:

initializeCatalog in class CatalogHandler

listGenericTables

public org.apache.polaris.service.types.ListGenericTablesResponse listGenericTables(org.apache.iceberg.catalog.Namespace parent)

createGenericTable

public org.apache.polaris.service.types.LoadGenericTableResponse createGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier,
 String format,
 String baseLocation,
 String doc,
 Map<String,String> properties)

dropGenericTable

public boolean dropGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier)

loadGenericTable

public org.apache.polaris.service.types.LoadGenericTableResponse loadGenericTable(org.apache.iceberg.catalog.TableIdentifier identifier)