Class InMemoryCatalogManager
java.lang.Object
org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalogManager
- All Implemented Interfaces:
CatalogManager
-
Constructor Summary
ConstructorsConstructorDescriptionInMemoryCatalogManager(MetaStore defaultMetastore) To keep backwards compatibility, extends an option to set a default metastore. -
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
-
InMemoryCatalogManager
public InMemoryCatalogManager() -
InMemoryCatalogManager
To keep backwards compatibility, extends an option to set a default metastore.
-
-
Method Details
-
createCatalog
Description copied from interface:CatalogManagerCreates and stores a catalog of a particular type.- Specified by:
createCatalogin interfaceCatalogManager
-
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
-
catalogs
- Specified by:
catalogsin interfaceCatalogManager
-