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: [email protected]
For additional commands, e-mail: [email protected]
