Package org.apache.beam.sdk.extensions.sql.meta.catalog

Class InMemoryCatalogManager

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.catalog.InMemoryCatalogManager

All Implemented Interfaces:

CatalogManager

public class InMemoryCatalogManager
extends Object
implements CatalogManager

Constructor Summary

Constructors

Constructor	Description
InMemoryCatalogManager()
InMemoryCatalogManager(MetaStore defaultMetastore)	To keep backwards compatibility, extends an option to set a default metastore.

Method Summary

Modifier and Type	Method	Description
Collection<Catalog>	catalogs()
void	createCatalog(String name, String type, Map<String,String> properties)	Creates and stores a catalog of a particular type.
Catalog	currentCatalog()	Produces the currently active catalog.
void	dropCatalog(String name)	Drops the catalog with this name.
@Nullable Catalog	getCatalog(String name)	Attempts to fetch the catalog with this name.
void	registerTableProvider(TableProvider tableProvider)	Registers a TableProvider and propagates it to all the Catalog instances available to this manager.
Map<String,TableProvider>	tableProviders()	Returns all the TableProviders available to this CatalogManager, organized by type.
void	useCatalog(String name)	Switches the active catalog.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryCatalogManager

public InMemoryCatalogManager()

InMemoryCatalogManager

public InMemoryCatalogManager(MetaStore defaultMetastore)

To keep backwards compatibility, extends an option to set a default metastore.

Method Details

createCatalog

public void createCatalog(String name,
 String type,
 Map<String,String> properties)

Description copied from interface: CatalogManager

Creates and stores a catalog of a particular type.

Specified by:

createCatalog in interface CatalogManager

useCatalog

public void useCatalog(String name)

Description copied from interface: CatalogManager

Switches the active catalog.

Specified by:

useCatalog in interface CatalogManager

currentCatalog

public Catalog currentCatalog()

Description copied from interface: CatalogManager

Produces the currently active catalog.

Specified by:

currentCatalog in interface CatalogManager

getCatalog

public @Nullable Catalog getCatalog(String name)

Description copied from interface: CatalogManager

Attempts to fetch the catalog with this name. May produce null if it does not exist.

Specified by:

getCatalog in interface CatalogManager

dropCatalog

public void dropCatalog(String name)

Description copied from interface: CatalogManager

Drops the catalog with this name. No-op if the catalog already does not exist.

Specified by:

dropCatalog in interface CatalogManager

registerTableProvider

public void registerTableProvider(TableProvider tableProvider)

Description copied from interface: CatalogManager

Registers a TableProvider and propagates it to all the Catalog instances available to this manager.

Specified by:

registerTableProvider in interface CatalogManager

tableProviders

public Map<String,TableProvider> tableProviders()

Description copied from interface: CatalogManager

Returns all the TableProviders available to this CatalogManager, organized by type.

Specified by:

tableProviders in interface CatalogManager

catalogs

public Collection<Catalog> catalogs()

Specified by:

catalogs in interface CatalogManager