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

Class EmptyCatalogManager

java.lang.Object

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

All Implemented Interfaces:

CatalogManager

public class EmptyCatalogManager
extends Object
implements CatalogManager

Constructor Summary

Constructors

Constructor	Description
EmptyCatalogManager()

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

EmptyCatalogManager

public EmptyCatalogManager()

Method Details

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

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

catalogs

public Collection<Catalog> catalogs()

Specified by:

catalogs in interface CatalogManager