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()

Method Summary

Modifier and Type	Method	Description
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(String name, TableProvider tableProvider)	Registers a TableProvider and propagates it to all the Catalog instances available to this manager.
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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.catalog.CatalogManager

registerTableProvider

Constructor Details

InMemoryCatalogManager

public InMemoryCatalogManager()

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(String name,
 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