public class FlinkCatalogFactory extends Object implements org.apache.flink.table.factories.CatalogFactory
FlinkCatalog
.Modifier and Type | Field and Description |
---|---|
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,
CatalogContext context,
ClassLoader classLoader) |
static FlinkCatalog |
createCatalog(String catalogName,
Catalog catalog,
Options options) |
static Catalog |
createPaimonCatalog(Options catalogOptions) |
String |
factoryIdentifier() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
optionalOptions() |
Set<org.apache.flink.configuration.ConfigOption<?>> |
requiredOptions() |
public static final String IDENTIFIER
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, CatalogContext context, ClassLoader classLoader)
public static FlinkCatalog createCatalog(String catalogName, Catalog catalog, Options options)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.