We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b31e1d commit 5416877Copy full SHA for 5416877
cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp/GcpFormatProvider.scala
@@ -26,12 +26,14 @@ class GcpFormatProvider(override val sparkSession: SparkSession) extends Default
26
cat match {
27
case delegating: DelegatingBigQueryMetastoreCatalog =>
28
Try {
29
- delegating
+ val providerString = delegating
30
.loadTable(identifier)
31
.properties
32
.asScala
33
.getOrElse(TableCatalog.PROP_PROVIDER, "")
34
- .toUpperCase match {
+ .toUpperCase
35
+ logger.info("GCPFormatProvider: Delegating catalog provider string: " + providerString)
36
+ providerString match {
37
case "ICEBERG" => Iceberg
38
case "BIGQUERY" => BigQueryNative
39
case "PARQUET" => BigQueryExternal
0 commit comments