public class FlinkCatalogFactory extends Object implements org.apache.flink.table.factories.CatalogFactory
FlinkCatalog
.Modifier and Type | Field and Description |
---|---|
static org.apache.flink.configuration.ConfigOption<String> |
DEFAULT_DATABASE |
static String |
IDENTIFIER |
Constructor and Description |
---|
FlinkCatalogFactory() |
Modifier and Type | Method and Description |
---|---|
FlinkCatalog |
createCatalog(org.apache.flink.table.factories.CatalogFactory.Context context) |
static FlinkCatalog |
createCatalog(String catalogName,
org.apache.flink.configuration.Configuration options,
ClassLoader classLoader) |
String |
factoryIdentifier() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
optionalOptions() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
requiredOptions() |
public static final String IDENTIFIER
public static final org.apache.flink.configuration.ConfigOption<String> DEFAULT_DATABASE
public String factoryIdentifier()
factoryIdentifier
in interface org.apache.flink.table.factories.CatalogFactory
factoryIdentifier
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
requiredOptions
in interface org.apache.flink.table.factories.CatalogFactory
requiredOptions
in interface org.apache.flink.table.factories.Factory
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
optionalOptions
in interface org.apache.flink.table.factories.CatalogFactory
optionalOptions
in interface org.apache.flink.table.factories.Factory
public FlinkCatalog createCatalog(org.apache.flink.table.factories.CatalogFactory.Context context)
createCatalog
in interface org.apache.flink.table.factories.CatalogFactory
public static FlinkCatalog createCatalog(String catalogName, org.apache.flink.configuration.Configuration options, ClassLoader classLoader)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.