org.apache.paimon.flink

Class FlinkGenericCatalogFactory

java.lang.Object

org.apache.paimon.flink.FlinkGenericCatalogFactory

All Implemented Interfaces:

org.apache.flink.table.factories.CatalogFactory, org.apache.flink.table.factories.Factory, org.apache.flink.table.factories.TableFactory

public class FlinkGenericCatalogFactory
extends Object
implements org.apache.flink.table.factories.CatalogFactory

Factory for FlinkGenericCatalog.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.CatalogFactory

org.apache.flink.table.factories.CatalogFactory.Context

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
FlinkGenericCatalogFactory()

Method Summary

Modifier and Type	Method and Description
FlinkGenericCatalog	createCatalog(org.apache.flink.table.factories.CatalogFactory.Context context)
static FlinkGenericCatalog	createCatalog(ClassLoader cl, Map<String,String> optionMap, String name, org.apache.flink.table.catalog.Catalog flinkCatalog)
String	factoryIdentifier()
org.apache.flink.table.factories.CatalogFactory.Context	filterContextOptions(org.apache.flink.table.factories.CatalogFactory.Context context, org.apache.flink.table.factories.CatalogFactory catalogFactory)
Set<org.apache.flink.configuration.ConfigOption<?>>	optionalOptions()
Set<org.apache.flink.configuration.ConfigOption<?>>	requiredOptions()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.CatalogFactory

createCatalog, requiredContext, supportedProperties

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

FlinkGenericCatalogFactory

public FlinkGenericCatalogFactory()

Method Detail

factoryIdentifier

public String factoryIdentifier()

Specified by:

factoryIdentifier in interface org.apache.flink.table.factories.CatalogFactory

Specified by:

factoryIdentifier in interface org.apache.flink.table.factories.Factory

requiredOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()

Specified by:

requiredOptions in interface org.apache.flink.table.factories.CatalogFactory

Specified by:

requiredOptions in interface org.apache.flink.table.factories.Factory

optionalOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()

Specified by:

optionalOptions in interface org.apache.flink.table.factories.CatalogFactory

Specified by:

optionalOptions in interface org.apache.flink.table.factories.Factory

createCatalog

public FlinkGenericCatalog createCatalog(org.apache.flink.table.factories.CatalogFactory.Context context)

Specified by:

createCatalog in interface org.apache.flink.table.factories.CatalogFactory

filterContextOptions

@VisibleForTesting
public org.apache.flink.table.factories.CatalogFactory.Context filterContextOptions(org.apache.flink.table.factories.CatalogFactory.Context context,
                                                                                                       org.apache.flink.table.factories.CatalogFactory catalogFactory)

createCatalog

@VisibleForTesting
public static FlinkGenericCatalog createCatalog(ClassLoader cl,
                                                                   Map<String,String> optionMap,
                                                                   String name,
                                                                   org.apache.flink.table.catalog.Catalog flinkCatalog)