Modifier and Type | Class and Description |
---|---|
class |
AbstractJdbcCatalog
Abstract catalog for any JDBC catalogs.
|
class |
JdbcCatalog
Catalogs for relational databases via JDBC.
|
class |
PostgresCatalog
Catalog for PostgreSQL.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
JdbcCatalogFactory.createCatalog(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
TableEnvironment.getCatalog(String catalogName)
Gets a registered
Catalog by name. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.registerCatalog(String catalogName,
Catalog catalog)
Registers a
Catalog under a unique name. |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
TableEnvironmentImpl.getCatalog(String catalogName) |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.registerCatalog(String catalogName,
Catalog catalog) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCatalog
Abstract class for catalogs.
|
class |
GenericInMemoryCatalog
A generic catalog implementation that holds all meta objects in memory.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
GenericInMemoryCatalogFactory.createCatalog(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
CatalogManager.getCatalog(String catalogName)
Gets a catalog by name.
|
Modifier and Type | Method and Description |
---|---|
CatalogManager.Builder |
CatalogManager.Builder.defaultCatalog(String defaultCatalogName,
Catalog defaultCatalog) |
void |
CatalogManager.registerCatalog(String catalogName,
Catalog catalog)
Registers a catalog under the given name.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalog
A catalog implementation for Hive.
|
Modifier and Type | Method and Description |
---|---|
Catalog |
HiveCatalogFactory.createCatalog(String name,
Map<String,String> properties) |
Modifier and Type | Method and Description |
---|---|
Map<String,Catalog> |
ExecutionContext.getCatalogs() |
Modifier and Type | Method and Description |
---|---|
Catalog |
CatalogFactory.createCatalog(String name,
Map<String,String> properties)
Creates and configures a
Catalog using the given properties. |
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
TableSinkFactory.Context context)
Creates a table sink for a
CatalogTable using table factory associated with the
catalog. |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSource from a CatalogTable . |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isStreamingMode,
boolean isTemporary)
Creates a
TableSink from a CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isTemporary)
Creates a
TableSource from a CatalogTable . |
Modifier and Type | Method and Description |
---|---|
Catalog |
CatalogSchemaTable.getCatalog() |
Constructor and Description |
---|
CatalogSchemaTable(ObjectIdentifier tableIdentifier,
CatalogManager.TableLookupResult lookupResult,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
Catalog catalog,
boolean isStreaming)
Create a CatalogSchemaTable instance.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.