An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs
This PR changes the API of the DeltaLog to take in an extra parameter for table catalog and switching some call sites (more to come) to use the new API version.
Which Delta project/connector is this regarding?
Description
This PR changes the API of the DeltaLog to take in an extra parameter for table catalog and switching some call sites (more to come) to use the new API version.
Delta log API changes
forTable(SparkSession, CatalogTable, Map[String, String])
forTableWithSnapshot(SparkSession, CatalogTable, Map[String, String])
withFreshSnapshot
to take in a catalog table.How was this patch tested?
Unit tests
Does this PR introduce any user-facing changes?
No