wip

Co-authored-by: Thomas Chow <[email protected]>

Author: tchow-zlai

cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp/DelegatingBigQueryMetastoreCatalog.scala

@@ -1,6 +1,5 @@
 package ai.chronon.integrations.cloud_gcp
 
-import com.google.cloud.spark.bigquery.BigQueryCatalog
 import com.google.cloud.bigquery.{
   BigQuery,
   BigQueryOptions,
@@ -9,10 +8,10 @@ import com.google.cloud.bigquery.{
   TableDefinition,
   TableId
 }
+import com.google.cloud.spark.bigquery.BigQueryCatalog
 import org.apache.iceberg.gcp.bigquery.BigQueryMetastoreCatalog
 import org.apache.iceberg.spark.SparkCatalog
 import org.apache.spark.sql.SparkSession
-import org.apache.spark.sql.catalyst.analysis.NoSuchTableException
 import org.apache.spark.sql.connector.catalog._
 import org.apache.spark.sql.connector.catalog.functions.UnboundFunction
 import org.apache.spark.sql.connector.expressions.Transform
@@ -23,6 +22,7 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap
 
 import java.util
 import scala.jdk.CollectionConverters._
+import org.apache.spark.sql.catalyst.analysis.NoSuchTableException
 import scala.util.{Failure, Success, Try}
 
 /** Galactus catalog that allows us to interact with BigQuery metastore as a spark catalog. This allows for
@@ -126,7 +126,6 @@ class DelegatingBigQueryMetastoreCatalog extends TableCatalog with SupportsNames
               // ideally it should be the below:
               // val connectorTable = connectorCatalog.loadTable(ident)
               connectorCatalog.loadTable(Identifier.of(Array(tId.getDataset), tId.getTable))
-
             }
             case _ => throw new IllegalStateException(s"Cannot support table of type: ${table.getDefinition}")
           }