@Experimental public interface CatalogExtension extends TableCatalog, SupportsNamespaces
setDelegateCatalog(CatalogPlugin)
, implement catalog functions with
some custom logic and call the built-in session catalog at the end. For example, they can
implement createTable
, do something else before calling createTable
of the
built-in session catalog.Modifier and Type | Method and Description |
---|---|
void |
setDelegateCatalog(CatalogPlugin delegate)
This will be called only once by Spark to pass in the Spark built-in session catalog, after
CatalogPlugin.initialize(String, CaseInsensitiveStringMap) is called. |
alterTable, createTable, dropTable, invalidateTable, listTables, loadTable, renameTable, tableExists
alterNamespace, createNamespace, defaultNamespace, dropNamespace, listNamespaces, listNamespaces, loadNamespaceMetadata, namespaceExists
initialize, name
void setDelegateCatalog(CatalogPlugin delegate)
CatalogPlugin.initialize(String, CaseInsensitiveStringMap)
is called.