Class StorageAccessConfigProvider
java.lang.Object
org.apache.polaris.service.catalog.io.StorageAccessConfigProvider
Provides temporary, scoped credentials for accessing table data in object storage (S3, GCS, Azure
Blob Storage).
This provider decouples credential vending from catalog implementations, and should be the primary entrypoint to get sub-scoped credentials for accessing table data.
-
Constructor Summary
ConstructorsConstructorDescriptionStorageAccessConfigProvider(org.apache.polaris.core.storage.cache.StorageCredentialCache storageCredentialCache, org.apache.polaris.core.storage.StorageCredentialsVendor storageCredentialsVendor) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.polaris.core.storage.StorageAccessConfiggetStorageAccessConfig(org.apache.iceberg.catalog.TableIdentifier tableIdentifier, Set<String> tableLocations, Set<org.apache.polaris.core.storage.PolarisStorageActions> storageActions, Optional<String> refreshCredentialsEndpoint, org.apache.polaris.core.persistence.PolarisResolvedPathWrapper resolvedPath) Vends credentials for accessing table storage at explicit locations.
-
Constructor Details
-
StorageAccessConfigProvider
@Inject public StorageAccessConfigProvider(org.apache.polaris.core.storage.cache.StorageCredentialCache storageCredentialCache, org.apache.polaris.core.storage.StorageCredentialsVendor storageCredentialsVendor)
-
-
Method Details
-
getStorageAccessConfig
public org.apache.polaris.core.storage.StorageAccessConfig getStorageAccessConfig(@Nonnull org.apache.iceberg.catalog.TableIdentifier tableIdentifier, @Nonnull Set<String> tableLocations, @Nonnull Set<org.apache.polaris.core.storage.PolarisStorageActions> storageActions, @Nonnull Optional<String> refreshCredentialsEndpoint, @Nonnull org.apache.polaris.core.persistence.PolarisResolvedPathWrapper resolvedPath) Vends credentials for accessing table storage at explicit locations.- Parameters:
tableIdentifier- the table identifier, used for logging and refresh endpoint constructiontableLocations- set of storage location URIs to scope credentials tostorageActions- the storage operations (READ, WRITE, LIST, DELETE) to scope credentials torefreshCredentialsEndpoint- optional endpoint URL for clients to refresh credentialsresolvedPath- the entity hierarchy to search for storage configuration- Returns:
StorageAccessConfigwith scoped credentials and metadata; empty if no storage config found
-