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(CatalogFactory.Context context) |
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(CatalogFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
Optional<Catalog> |
CatalogManager.TableLookupResult.getCatalog() |
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) |
static CatalogManager.TableLookupResult |
CatalogManager.TableLookupResult.permanent(Catalog catalog,
ResolvedCatalogBaseTable<?> resolvedTable) |
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(CatalogFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
default Catalog |
CatalogFactory.createCatalog(CatalogFactory.Context context)
Creates and configures a
Catalog using the given context. |
default Catalog |
CatalogFactory.createCatalog(String name,
Map<String,String> properties)
Deprecated.
Use
this#createCatalog(Context) instead and implement Factory
instead of TableFactory . |
static Catalog |
FactoryUtil.createCatalog(String catalogName,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader)
Attempts to discover an appropriate catalog factory and creates an instance of the catalog.
|
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable 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,
ResolvedCatalogTable 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 |
---|---|
Optional<Catalog> |
CatalogSchemaTable.getCatalog() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.