Skip to content

Commit 49ed145

Browse files
committed
spark: add UC Delta Rest Catalog API path credentials for raw path reads
1 parent c06175b commit 49ed145

14 files changed

Lines changed: 719 additions & 141 deletions

File tree

spark/src/main/scala/org/apache/spark/sql/delta/catalog/AbstractDeltaCatalog.scala

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,14 @@ class AbstractDeltaCatalog extends DelegatingCatalogExtension
292292
"DeltaCatalog", "loadTable") {
293293
setVariantBlockingConfigIfUC()
294294
try {
295-
val table = deltaCatalogClient.loadTable(ident).getOrElse(super.loadTable(ident))
295+
val table =
296+
if (isPathIdentifier(ident)) {
297+
loadPathTable(ident)
298+
} else if (isIcebergPathIdentifier(ident)) {
299+
newIcebergPathTable(ident)
300+
} else {
301+
deltaCatalogClient.loadTable(ident).getOrElse(super.loadTable(ident))
302+
}
296303

297304
ServerSidePlannedTable.tryCreate(spark, ident, table, isUnityCatalog).foreach { sspt =>
298305
return sspt

0 commit comments

Comments
 (0)