org.apache.flink.table.descriptors

Class CatalogDescriptor

java.lang.Object

org.apache.flink.table.descriptors.DescriptorBase

org.apache.flink.table.descriptors.CatalogDescriptor

All Implemented Interfaces:

Descriptor

Direct Known Subclasses:

GenericInMemoryCatalogDescriptor, HiveCatalogDescriptor, JdbcCatalogDescriptor

@PublicEvolving
public abstract class CatalogDescriptor
extends DescriptorBase

Describes a catalog of tables, views, and functions.

Constructor Summary

Constructors

Constructor and Description
CatalogDescriptor(String type, int propertyVersion) Constructs a CatalogDescriptor.
CatalogDescriptor(String type, int propertyVersion, String defaultDatabase) Constructs a CatalogDescriptor.

Method Summary

Modifier and Type	Method and Description
String	getDefaultDatabase()
protected abstract Map<String,String>	toCatalogProperties() Converts this descriptor into a set of catalog properties.
Map<String,String>	toProperties() Converts this descriptor into a set of properties.

Methods inherited from class org.apache.flink.table.descriptors.DescriptorBase

toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CatalogDescriptor

public CatalogDescriptor(String type,
                         int propertyVersion)

Constructs a CatalogDescriptor.

Parameters:

type - string that identifies this catalog

propertyVersion - property version for backwards compatibility

CatalogDescriptor

public CatalogDescriptor(String type,
                         int propertyVersion,
                         String defaultDatabase)

Constructs a CatalogDescriptor.

Parameters:

type - string that identifies this catalog

propertyVersion - property version for backwards compatibility

defaultDatabase - default database of the catalog

Method Detail

toProperties

public final Map<String,String> toProperties()

Description copied from interface: Descriptor

Converts this descriptor into a set of properties.

getDefaultDatabase

public String getDefaultDatabase()

toCatalogProperties

protected abstract Map<String,String> toCatalogProperties()

Converts this descriptor into a set of catalog properties.