Skip to content

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:

Initialize 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:

Name

String name()

SHOW CURRENT NAMESPACE

Use SHOW CURRENT NAMESPACE command to display the name.

Implementations

Demo

Learn more in Demo: Developing CatalogPlugin.