org.apache.flink.table.catalog.listener

Interface CatalogContext

@PublicEvolving
public interface CatalogContext

Context for catalog which provides the name, factory identifier and configuration to identify the same physical catalog for different logical catalog. For example, catalogs with different catalog name may be created on the same physical catalog.

Method Summary

Modifier and Type	Method and Description
static CatalogContext	createContext(String catalogName, Catalog catalog)
String	getCatalogName() The catalog name.
Class<? extends Catalog>	getClazz() Class of the catalog.
Configuration	getConfiguration() The catalog configuration.
Optional<String>	getFactoryIdentifier() Identifier for the catalog from factory which is used to create dynamic tables.

Method Detail

getCatalogName

String getCatalogName()

The catalog name.

getFactoryIdentifier

Optional<String> getFactoryIdentifier()

Identifier for the catalog from factory which is used to create dynamic tables. Notice that the factory for hive catalog will throw an exception, you can use getClazz to get catalog class.

getClazz

@Nullable
Class<? extends Catalog> getClazz()

Class of the catalog.

getConfiguration

Configuration getConfiguration()

The catalog configuration.

createContext

static CatalogContext createContext(String catalogName,
                                    Catalog catalog)