Class EmptyCatalogManager
java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.catalog.EmptyCatalogManager
- All Implemented Interfaces:
CatalogManager
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncatalogs()voidCreates and stores a catalog of a particular type.Produces the currently active catalog.voiddropCatalog(String name) Drops the catalog with this name.getCatalog(String name) Attempts to fetch the catalog with this name.voidregisterTableProvider(TableProvider tableProvider) Registers aTableProviderand propagates it to all theCataloginstances available to this manager.Returns all theTableProviders available to thisCatalogManager, organized by type.voiduseCatalog(String name) Switches the active catalog.
-
Constructor Details
-
EmptyCatalogManager
public EmptyCatalogManager()
-
-
Method Details
-
useCatalog
Description copied from interface:CatalogManagerSwitches the active catalog.- Specified by:
useCatalogin interfaceCatalogManager
-
currentCatalog
Description copied from interface:CatalogManagerProduces the currently active catalog.- Specified by:
currentCatalogin interfaceCatalogManager
-
getCatalog
Description copied from interface:CatalogManagerAttempts to fetch the catalog with this name. May produce null if it does not exist.- Specified by:
getCatalogin interfaceCatalogManager
-
dropCatalog
Description copied from interface:CatalogManagerDrops the catalog with this name. No-op if the catalog already does not exist.- Specified by:
dropCatalogin interfaceCatalogManager
-
registerTableProvider
Description copied from interface:CatalogManagerRegisters aTableProviderand propagates it to all theCataloginstances available to this manager.- Specified by:
registerTableProviderin interfaceCatalogManager
-
tableProviders
Description copied from interface:CatalogManagerReturns all theTableProviders available to thisCatalogManager, organized by type.- Specified by:
tableProvidersin interfaceCatalogManager
-
createCatalog
Description copied from interface:CatalogManagerCreates and stores a catalog of a particular type.- Specified by:
createCatalogin interfaceCatalogManager
-
catalogs
- Specified by:
catalogsin interfaceCatalogManager
-