Github user rdblue commented on a diff in the pull request: https://github.com/apache/spark/pull/21306#discussion_r205237682 --- Diff: sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala --- @@ -609,6 +611,12 @@ class SparkSession private( */ @transient lazy val catalog: Catalog = new CatalogImpl(self) + @transient private lazy val catalogs = new mutable.HashMap[String, CatalogProvider]() + + private[sql] def catalog(name: String): CatalogProvider = synchronized { --- End diff -- Note that this is `private[sql]`. This allows us to use the named `TableCatalog` instances without solving how multiple catalogs should be exposed to users through a public API just yet.
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org