CatalogPlugin¶
CatalogPlugin is an abstraction of table catalogs.
CatalogHelper
CatalogHelper is a Scala implicit class of CatalogPlugin with extensions methods.
Contract¶
Default Namespace¶
String[] defaultNamespace()
Default namespace
Default: (empty)
Used when:
CatalogManageris requested for the current namespace
Initializing CatalogPlugin¶
void initialize(
String name,
CaseInsensitiveStringMap options)
Initializes this CatalogPlugin with the following:
- Name that was used in
spark.sql.catalog.[name]configuration property spark.sql.catalog.[name].-prefixed case-insensitive options
Used when:
Catalogsutility is used to load a catalog by name
Name¶
String name()
SHOW CURRENT NAMESPACE
Use SHOW CURRENT NAMESPACE command to display the name.
Implementations¶
Demo¶
Learn more in Demo: Developing CatalogPlugin.