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 java.lang.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
java.util.Collection<Catalog>	catalogs()
void	createCatalog(java.lang.String name, java.lang.String type, java.util.Map<java.lang.String,java.lang.String> properties)	Creates and stores a catalog of a particular type.
Catalog	currentCatalog()	Produces the currently active catalog.
void	dropCatalog(java.lang.String name)	Drops the catalog with this name.
@Nullable Catalog	getCatalog(java.lang.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.
java.util.Map<java.lang.String,TableProvider>	tableProviders()	Returns all the TableProviders available to this CatalogManager, organized by type.
void	useCatalog(java.lang.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 Detail

InMemoryCatalogManager

public InMemoryCatalogManager()

InMemoryCatalogManager

public InMemoryCatalogManager(MetaStore defaultMetastore)

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

Method Detail

createCatalog

public void createCatalog(java.lang.String name,
                          java.lang.String type,
                          java.util.Map<java.lang.String,java.lang.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(java.lang.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(java.lang.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(java.lang.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 java.util.Map<java.lang.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 java.util.Collection<Catalog> catalogs()

Specified by:

catalogs in interface CatalogManager