diff --git a/pyiceberg/io/__init__.py b/pyiceberg/io/__init__.py index 0b03a7dd4f..f89de18f12 100644 --- a/pyiceberg/io/__init__.py +++ b/pyiceberg/io/__init__.py @@ -74,6 +74,7 @@ HDFS_USER = "hdfs.user" HDFS_KERB_TICKET = "hdfs.kerberos_ticket" ADLS_CONNECTION_STRING = "adls.connection-string" +ADLS_CREDENTIAL = "adls.credential" ADLS_ACCOUNT_NAME = "adls.account-name" ADLS_ACCOUNT_KEY = "adls.account-key" ADLS_SAS_TOKEN = "adls.sas-token" diff --git a/pyiceberg/io/fsspec.py b/pyiceberg/io/fsspec.py index 6febff0ae6..d075765ed1 100644 --- a/pyiceberg/io/fsspec.py +++ b/pyiceberg/io/fsspec.py @@ -45,6 +45,7 @@ ADLS_CLIENT_ID, ADLS_CLIENT_SECRET, ADLS_CONNECTION_STRING, + ADLS_CREDENTIAL, ADLS_SAS_TOKEN, ADLS_TENANT_ID, AWS_ACCESS_KEY_ID, @@ -203,6 +204,7 @@ def _adls(properties: Properties) -> AbstractFileSystem: return AzureBlobFileSystem( connection_string=properties.get(ADLS_CONNECTION_STRING), + credential=properties.get(ADLS_CREDENTIAL), account_name=properties.get(ADLS_ACCOUNT_NAME), account_key=properties.get(ADLS_ACCOUNT_KEY), sas_token=properties.get(ADLS_SAS_TOKEN),